celery_queu_config.py 文件源码

def build_queues(cls):
        default_exchange = Exchange(cls.default_name, type='direct')

        queues = [
            Queue(cls.default_name, default_exchange, routing_key=cls.default_name),
            Queue(cls.system_name, default_exchange, routing_key=cls.system_name)
        ]
        return tuple(set(queues))