

def _queue(self, conn=None):
    exchange = kombu.Exchange(conn.channel, type='fanout', durable=False)
    queue = kombu.Queue(str(uuid.uuid4()), exchange)
    return queue

dataset/ETHPy150Open miguelgrinberg/python-socketio/socketio/kombu_manager.py KombuManager._queue/VarMisuse@20/25 `self`->`conn`