<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 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)