Skip to content

Commit 8e486f3

Browse files
committed
Make queues durable
1 parent 822299c commit 8e486f3

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

app/amqp/amqp.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,7 @@ def _bind_queue(channel: BlockingChannel, name: str, exchange_name: str) -> None
143143
:param str name: Name of the queue
144144
:param str exchange_name: Name of the exchange
145145
"""
146-
channel.queue_declare(queue=name, durable=True, exclusive=False, auto_delete=True, arguments=None)
146+
channel.queue_declare(queue=name, durable=True, exclusive=False, auto_delete=False, arguments=None)
147147
channel.queue_bind(exchange=exchange_name, queue=name, routing_key=name)
148148

149149
@staticmethod

0 commit comments

Comments
 (0)