messaging.py 文件源码

def setup(self):
        super(ReplyConsumer, self).setup()
        config = self.container.config

        """Declare consumer queue for this service in current region"""
        self.queue = Queue(
            exchange=orders_exchange,
            routing_key='{}_{}'.format(
                config['REGION'],
                ROUTING_KEY_CALCULATE_TAXES
            ),
            name='fed.{}_{}'.format(
                config['REGION'], ROUTING_KEY_CALCULATE_TAXES
            )
        )

        """Bind federated queues in all regions to
            `orders` exchange with correct routing key.
        """
        with get_connection(config[AMQP_URI_CONFIG_KEY]) as connection:

            maybe_declare(orders_exchange, connection)

            self._bind_queues_in_for_all_regions(
                ROUTING_KEY_CALCULATE_TAXES, connection
            )
            self._bind_queues_in_for_all_regions(
                ROUTING_KEY_CALCULATE_TAXES_REPLY, connection
            )