def basic_consume(self,
                      consumer_callback,
                      queue,
                      no_ack=False,
                      exclusive=False,
                      consumer_tag=None,
                      arguments=None):
        if not callable(consumer_callback):
            raise ValueError('consumer callback must be callable; got %r'
                             % consumer_callback)

        return self._basic_consume_impl(
            queue=queue,
            no_ack=no_ack,
            exclusive=exclusive,
            consumer_tag=consumer_tag,
            arguments=arguments,
            consumer_callback=consumer_callback)
Sends the AMQP command Basic.Consume to the broker and binds messages
dataset/ETHPy150Open pika/pika/pika/adapters/blocking_connection.py/BlockingChannel.basic_consume