docs: def on_delivery(self, name, channel, method, properties, body):
          """Process a message from Rabbit
  
          :param str name: The connection name
          :param pika.channel.Channel channel: The message's delivery channel
          :param pika.frames.MethodFrame method: The method frame
          :param pika.spec.BasicProperties properties: The message properties
          :param str body: The message body
  
          """
          message = data.Message(name, channel, method, properties, body)
          if self.is_processing:
              return self.pending.append(message)
          self.invoke_consumer(message)