test

Bogdanp · Apr 24, 2024 · d151075 · d151075
1 parent a7f2cef
commit d151075
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dramatiq/brokers/rabbitmq.py b/dramatiq/brokers/rabbitmq.py
@@ -312,7 +312,6 @@ def enqueue(self, message, *, delay=None):
             has been closed.
         """
         queue_name = message.queue_name
-        self.declare_queue(queue_name, ensure=True)
 
         if delay is not None:
             queue_name = dq_name(queue_name)
@@ -327,6 +326,7 @@ def enqueue(self, message, *, delay=None):
         attempts = 1
         while True:
             try:
+                self.declare_queue(queue_name, ensure=True)
                 self.logger.debug("Enqueueing message %r on queue %r.", message.message_id, queue_name)
                 self.emit_before("enqueue", message, delay)
                 self.channel.basic_publish(