Quellcode durchsuchen

Respect Exchange.delivery_mode (depends on celery/kombu@b6c3f99f66ccdcd359ed92dd8c59174cc0f1c0d3) Closes #1953

Ask Solem vor 10 Jahren
Ursprung
Commit
5222f8bd8a
1 geänderte Dateien mit 2 neuen und 1 gelöschten Zeilen
  1. 2 1
      celery/app/amqp.py

+ 2 - 1
celery/app/amqp.py

@@ -438,7 +438,8 @@ class AMQP(object):
                 try:
                     delivery_mode = queue.exchange.delivery_mode
                 except AttributeError:
-                    delivery_mode = default_delivery_mode
+                    pass
+                delivery_mode = delivery_mode or default_delivery_mode
             exchange = exchange or queue.exchange.name
             routing_key = routing_key or queue.routing_key
             if declare is None and queue and not isinstance(queue, Broadcast):