fix: make sure RabbitMQ broker’s enqueue() attempts the correct numbe…

…r of preset retries (#669)
Bogdanp · Dec 22, 2024 · b372f43 · b372f43
1 parent 4dd0d71
commit b372f43
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dramatiq/brokers/rabbitmq.py b/dramatiq/brokers/rabbitmq.py
@@ -246,7 +246,7 @@ def declare_queue(self, queue_name, *, ensure=False):
             self._ensure_queue(queue_name)
 
     def _ensure_queue(self, queue_name):
-        attempts = 1
+        attempts = 0
         while True:
             try:
                 if queue_name in self.queues_pending:
@@ -321,7 +321,7 @@ def enqueue(self, message, *, delay=None):
                 },
             )
 
-        attempts = 1
+        attempts = 0
         while True:
             try:
                 self.declare_queue(canonical_queue_name, ensure=True)