

def setup():
    conn = connect()
    if (conn is None):
        return
    conn._close_cb = create_connection_closed_cb(conn)
    channel = conn.channel()
    runner.basic.qos(prefetch_count=1)
    runner = create_runner(channel)
    channel.basic.consume(queue=QUEUE, consumer=runner, no_ack=False)
    while (conn.close_info is None):
        conn.read_frames()
    sys.exit(1)

dataset/ETHPy150Open seatgeek/cronq/cronq/runner.py setup/VarMisuse@44/51 `channel`->`runner`