This method just handles AMQP connection details and receive loop.

        Warning:
            Don't override this method!

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)