'Consume from `queue`.'

def basic_consume(self, queue, no_ack, callback, consumer_tag, **kwargs):

    self._tag_to_queue[consumer_tag] = queue
    self._active_queues.append(queue)
    def _callback(raw_message):
        message = self.Message(raw_message, channel=self)
        if (not no_ack):
            self.qos.append(message, message.delivery_tag)
        return callback(message)
    self.connection._callbacks[queue] = _callback
    self._consumers.add(consumer_tag)
    self._reset_cycle()
