amqp/client.py
def on_queue_declareok(self, method_frame, queue_info, exchange_name):
        """Method invoked by pika when the Queue.Declare RPC call made in
        setup_queue has completed. In this method we will bind the queue
        and exchange together with the routing key by issuing the Queue.Bind
        RPC command. When this command == complete, the on_bindok method will
        be invoked by pika.

        :param pika.frame.Method method_frame: The Queue.DeclareOk frame

        """
        for key in queue_info['routing']:
            self.logger.info('Exchange %s: Binding %s with %s',
                        exchange_name, queue_info['queue'], key)
            self._channel.queue_bind(lambda x: self.on_bindok(x, queue_info), queue_info['queue'],
                                     exchange_name, key)
Method invoked by pika when the Queue.Declare RPC call made in
        setup_queue has completed. In this method we will bind the queue
        and exchange together with the routing key by issuing the Queue.Bind
        RPC command. When this command == complete, the on_bindok method will
        be invoked by pika.

        :param pika.frame.Method method_frame: The Queue.DeclareOk frame

        
Method invoked by pika when the Queue.Declare RPC call made in
setup_queue has completed. In this method we will bind the queue
and exchange together with the routing key by issuing the Queue.Bind
RPC command. When this command == complete, the on_bindok method will
be invoked by pika.
Method invoked by pika when the Queue . Declare RPC call made in setup_queue has completed . In this method we will bind the queue and exchange together with the routing key by issuing the Queue . Bind RPC command . When this command == complete the on_bindok method will be invoked by pika .
def on_queue_declareok(self, method_frame, queue_info, exchange_name):
        for key in queue_info['routing']:
            self.logger.info('Exchange %s: Binding %s with %s',
                        exchange_name, queue_info['queue'], key)
            self._channel.queue_bind(lambda x: self.on_bindok(x, queue_info), queue_info['queue'],
                                     exchange_name, key)
def on_queue_declareok ( self , method_frame , queue_info , exchange_name ) : for key in queue_info [ 'routing' ] : self . logger . info ( 'Exchange %s: Binding %s with %s' , exchange_name , queue_info [ 'queue' ] , key ) self . _channel . queue_bind ( lambda x : self . on_bindok ( x , queue_info ) , queue_info [ 'queue' ] , exchange_name , key )
Method invoked by pika when the Queue.Declare RPC call made in
setup_queue has completed.
Method invoked by pika when the Queue . Declare RPC call made in setup_queue has completed .
"""Method invoked by pika when the Queue.Declare RPC call made in
        setup_queue has completed. In this method we will bind the queue
        and exchange together with the routing key by issuing the Queue.Bind
        RPC command. When this command == complete, the on_bindok method will
        be invoked by pika.

        :param pika.frame.Method method_frame: The Queue.DeclareOk frame

        """
self
method_frame
The Queue.DeclareOk frame
The Queue . DeclareOk frame
queue_info
exchange_name