Marmelator/pyinfra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 36 Wiki Activity

change request_queue to durable=True

Browse Source
This commit is contained in:
Julius Unverfehrt 2022-03-17 12:45:49 +01:00
parent 391bcc482f
commit 3b50f88482
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pyinfra/queue/queue_manager/pika_queue_manager.py
View File

@ -74,8 +74,8 @@ class PikaQueueManager(QueueManager):
args = {"x-dead-letter-exchange": "", "x-dead-letter-routing-key": dead_letter_queue}
self.channel.queue_declare(input_queue, arguments=args, auto_delete=False)
self.channel.queue_declare(output_queue, arguments=args, auto_delete=False)
self.channel.queue_declare(input_queue, arguments=args, auto_delete=False, durable=True)
self.channel.queue_declare(output_queue, arguments=args, auto_delete=False, durable=True)
def republish(self, body, n_current_attempts, frame):
self.channel.basic_publish(