@defer.inlineCallbacks
    def thriftBasicReturnQueue(self, key):
        yield self.thriftBasicReturnQueueLock.acquire()
        try:
            try:
                q = self.thriftBasicReturnQueues[key]
            except __HOLE__:
                q = TimeoutDeferredQueue()
                self.thriftBasicReturnQueues[key] = q
        finally:
            self.thriftBasicReturnQueueLock.release()
        defer.returnValue(q)
dataset/ETHPy150Open tweetdeck/txAMQP/src/txamqp/contrib/thrift/protocol.py/ThriftAMQClient.thriftBasicReturnQueue