proper closing with multiple queues

[heycalmdown]

I need multiple threads to consume multiple queues. Channels can not be shared through threads, so the each thread should make their own.

def thread_rpc_queue(connection, queueName):
    with connection.channel() as ch:
        q = rabbitpy.Queue(ch, queueName)
        q.declare()

        for msg in q:
            print('yay')
            msg.ack()

for i in range(10):
    t = threading.Thread(target=thread_rpc_queue, kwargs={'connection': conn, 'queueName': 'q.' + str(i)})
    t.start()

But because of conn.close() will delete its channels in the main thread, I'm getting several errors like by random;

• rabbitpy.exceptions.ChannelClosedException: Can not perform RPC requests on a closed channel, you must create a new channel
• rabbitpy.exceptions.ConnectionClosed: The connection is closed
• RuntimeError: dictionary changed size during iteration

Could you give me some advice how to handle multiple queues and close properly?

[DanSchum]

Good question. Facing similar problem. Any updates?

[gmr]

Create the connection directly without using it as a context manager:

conn = rabbitpy.Connection(...)

Then pass that in your threads and create your channel in the thread.

[DanSchum]

I saved all my active queues (from different threads) and before closing the connection I cancel the consuming of these queue gracefully. This works pretty good for me.