Jelajahi Sumber

Routing Table: routing_key is set to the binding_key by default

Ask Solem 15 tahun lalu
induk
melakukan
54a370abd6
1 mengubah file dengan 1 tambahan dan 0 penghapusan
  1. 1 0
      celery/conf.py

+ 1 - 0
celery/conf.py

@@ -240,6 +240,7 @@ def _init_routing_table(queues):
         opts.setdefault("exchange", DEFAULT_EXCHANGE),
         opts.setdefault("exchange", DEFAULT_EXCHANGE),
         opts.setdefault("exchange_type", DEFAULT_EXCHANGE_TYPE)
         opts.setdefault("exchange_type", DEFAULT_EXCHANGE_TYPE)
         opts.setdefault("binding_key", DEFAULT_EXCHANGE)
         opts.setdefault("binding_key", DEFAULT_EXCHANGE)
+        opts.setdefault("routing_key", opts.get("binding_key"))
         return opts
         return opts
 
 
     return dict((queue, _defaults(opts)) for queue, opts in queues.items())
     return dict((queue, _defaults(opts)) for queue, opts in queues.items())