Browse Source

autoexchange was being ignored

Ask Solem 9 năm trước cách đây
mục cha
commit
5d144c94b5
1 tập tin đã thay đổi với 1 bổ sung2 xóa
  1. 1 2
      celery/app/amqp.py

+ 1 - 2
celery/app/amqp.py

@@ -91,8 +91,7 @@ class Queues(dict):
             return dict.__getitem__(self, name)
             return dict.__getitem__(self, name)
 
 
     def __setitem__(self, name, queue):
     def __setitem__(self, name, queue):
-        if self.default_exchange and (not queue.exchange or
-                                      not queue.exchange.name):
+        if self.default_exchange and not queue.exchange:
             queue.exchange = self.default_exchange
             queue.exchange = self.default_exchange
         dict.__setitem__(self, name, queue)
         dict.__setitem__(self, name, queue)
         if queue.alias:
         if queue.alias: