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)
def body ( self ) : self . connection = pika . BlockingConnection ( self . connection_param ) self . channel = self . connection . channel ( ) for method_frame , properties , body in self . channel . consume ( self . queue ) : if self . onMessageReceived ( method_frame , properties , body ) : self . ack ( method_frame . delivery_tag )
This method just handles AMQP connection details and receive loop.

        Warning:
            Don't override this method!