docs: 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
  
          """
          msg = 'Consumer was cancelled remotely, shutting down: {0!r}'
          logger.info(msg.format(method_frame))
          if self._channel:
              self._channel.close()