AMQP result backend is now durable

mher · Dec 28, 2013 · f9e67a3 · f9e67a3
1 parent fa92704
commit f9e67a3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tcelery/connection.py b/tcelery/connection.py
@@ -99,7 +99,7 @@ def consume(self, queue, callback, x_expires=None):
         assert self.channel
         self.channel.queue_declare(self.on_queue_declared, queue=queue,
                                    exclusive=False, auto_delete=True,
-                                   nowait=True,
+                                   nowait=True, durable=True,
                                    arguments={'x-expires': x_expires})
         self.channel.basic_consume(callback, queue, no_ack=True)