@inlineCallbacks
    def consume(self, queueName):
        reply = yield self.channel.basic_consume(queue=queueName, no_ack=True)
        returnValue((yield self.client.queue(reply.consumer_tag)))
Test host address translation
dataset/ETHPy150Open tweetdeck/txAMQP/src/txamqp/testlib.py/TestBase.consume--crossover with--dataset/ETHPy150Open datastax/python-driver/tests/integration/standard/test_cluster.py/TestAddressTranslation.test_address_translator_basic