docs: def add_on_cancel_callback(self):
          """
          Add a callback that will be invoked if RabbitMQ cancels the consumer
          for some reason. If RabbitMQ does cancel the consumer,
          on_consumer_cancelled will be invoked by pika.
          """
          self._logger.info('Adding consumer cancellation callback')
          self._channel.add_on_cancel_callback(self.on_consumer_cancelled)