docs: def body(self):
          """
          This method just handles AMQP connection details and receive loop.
  
          Warning:
              Don't override this method!
          """
          self.connection = pika.BlockingConnection(self.connection_param)
          self.channel = self.connection.channel()
  
          # receive messages and put them to .onMessageReceived() callback
          for method_frame, properties, body in self.channel.consume(self.queue):
              if self.onMessageReceived(method_frame, properties, body):
                  self.ack(method_frame.delivery_tag)