From 3b50f88482d74ea39240cdd41cc7dd62076c87b7 Mon Sep 17 00:00:00 2001 From: Julius Unverfehrt Date: Thu, 17 Mar 2022 12:45:49 +0100 Subject: [PATCH] change request_queue to durable=True --- pyinfra/queue/queue_manager/pika_queue_manager.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pyinfra/queue/queue_manager/pika_queue_manager.py b/pyinfra/queue/queue_manager/pika_queue_manager.py index 6cfae52..75e1596 100644 --- a/pyinfra/queue/queue_manager/pika_queue_manager.py +++ b/pyinfra/queue/queue_manager/pika_queue_manager.py @@ -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(