@inlineCallbacks
    def consume(self, queueName):
        reply = yield self.channel.basic_consume(queue=queueName, no_ack=True)
        returnValue((yield self.client.queue(reply.consumer_tag)))
Consume from named queue returns the Queue object.
dataset/ETHPy150Open tweetdeck/txAMQP/src/txamqp/testlib.py/TestBase.consume