messaging.py 文件源码

def _bind_queues_in_for_all_regions(self, routing_key, connection):
        for region in REGIONS:
                maybe_declare(Queue(
                    exchange=orders_exchange,
                    routing_key='{}_{}'.format(
                        region, routing_key
                    ),
                    name='fed.{}_{}'.format(
                        region, routing_key
                    )
                ), connection)