def start_consuming(self):
self.add_on_cancel_callback()<EOL>self._consumer_tag = self._channel.basic_consume(self.on_message,<EOL>self._queue)<EOL>logger.info('<STR_LIT>')<EOL>
Sets up the consumer.

        We do this by first calling add_on_cancel_callback so that the
        object is notified if RabbitMQ cancels the consumer. Then we issue
        a Basic.Consume command which returns the consumer tag that is used
        to uniquely identify the consumer with RabbitMQ. We keep the value
        to use it when we want to cancel consuming.

        The on_message method is passed in as a callback pika will invoke
        when a message is fully received.