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(