messaging.py 文件源码

def setup(self):
        reply_queue_name = "{}_{}".format(
            self.container.config['REGION'], ROUTING_KEY_CALCULATE_TAXES_REPLY
        )
        queue = Queue(
            exchange=orders_exchange,
            routing_key=reply_queue_name,
            name='fed.{}'.format(reply_queue_name)
        )
        self.queue = queue
        super(DynamicConsumer, self).setup()