Queues should be durable

This commit is contained in:
Serg Melikyan 2013-03-12 13:37:27 +04:00
parent c3a040ca6b
commit 1d98866235
1 changed files with 1 additions and 1 deletions

View File

@ -35,7 +35,7 @@ class TaskResultHandlerService(service.Service):
def bind(exchange, queue):
if not exchange:
ch.exchange_declare(exchange, 'direct', durable=True, auto_delete=False)
ch.queue_declare(queue)
ch.queue_declare(queue, durable=True, auto_delete=False)
if not exchange:
ch.queue_bind(queue, exchange, queue)