amqp/client.py
def on_consumer_cancelled(self, method_frame):
        """Invoked by pika when RabbitMQ sends a Basic.Cancel for a consumer
        receiving messages.

        :param pika.frame.Method method_frame: The Basic.Cancel frame

        """
        self.logger.info('Consumer was cancelled remotely, shutting down: %r',
                    method_frame)
        if self._channel:
            self._channel.close()
Invoked by pika when RabbitMQ sends a Basic.Cancel for a consumer
        receiving messages.

        :param pika.frame.Method method_frame: The Basic.Cancel frame

        
Invoked by pika when RabbitMQ sends a Basic.Cancel for a consumer
receiving messages.
Invoked by pika when RabbitMQ sends a Basic . Cancel for a consumer receiving messages .
def on_consumer_cancelled(self, method_frame):
        self.logger.info('Consumer was cancelled remotely, shutting down: %r',
                    method_frame)
        if self._channel:
            self._channel.close()
def on_consumer_cancelled ( self , method_frame ) : self . logger . info ( 'Consumer was cancelled remotely, shutting down: %r' , method_frame ) if self . _channel : self . _channel . close ( )
Invoked by pika when RabbitMQ sends a Basic.Cancel for a consumer
receiving messages.
Invoked by pika when RabbitMQ sends a Basic . Cancel for a consumer receiving messages .
"""Invoked by pika when RabbitMQ sends a Basic.Cancel for a consumer
        receiving messages.

        :param pika.frame.Method method_frame: The Basic.Cancel frame

        """
self
method_frame
The Basic.Cancel frame
The Basic . Cancel frame