Fixed issue with x-expires

Incorrect type was choosen for value of x-expires arg

Closed-bug: #1255042
Change-Id: I11f2e11965b0f1f0b2fb016672619cd625dde86c
This commit is contained in:
Serg Melikyan 2013-11-26 15:29:00 +04:00
parent d633884312
commit 91cc53dd24

View File

@ -70,7 +70,7 @@ class MqClient(object):
# configure RabbitMQ.
queue_args['x-ha-policy'] = 'all'
if ttl > 0:
queue_args['x-expires'] = str(ttl)
queue_args['x-expires'] = ttl
promise = self._client.queue_declare(
str(queue), durable=True, arguments=queue_args