def on_message(self, channel=None, method=None, properties=None, body=None):
        """Process a message from Rabbit

        :param pika.channel.Channel channel: The channel the message was sent on
        :param pika.frames.MethodFrame method: The method frame
        :param pika.spec.BasicProperties properties: The message properties
        :param str body: The message body

        """
        if method.redelivered:
            self.stats.incr(self.REDELIVERED)
        try:
            self.invoke_consumer(data.Message(channel, method, properties,
                                              body))
        except __HOLE__:
            pass
dataset/ETHPy150Open gmr/rejected/rejected/process.py/Process.on_message