

def _listen(self):
    reader_conn = kombu.Connection(reader_queue.url)
    reader_queue = self._queue(reader_conn)
    with reader_conn.SimpleQueue(reader_queue) as queue:
        while True:
            message = queue.get(block=True)
            message.ack()
            (yield message.payload)

dataset/ETHPy150Open miguelgrinberg/python-socketio/socketio/kombu_manager.py KombuManager._listen/VarMisuse@16/23 `self`->`reader_queue`