[rabbitmq-discuss] Create many queues with Pika

Mon Mar 19 15:02:42 GMT 2012

Hello everyone,

I'm in a situation where I need to create a lot of queues, let's say 20,
using Pika 0.9.5.
I'm currently using the SelectConnection module which works with callbacks.

I don't want to cascade 20 consecutive callbacks to achieve this:

def on_channel_open(channel_):
>     global channel
>     channel = channel_
>     channel.queue_declare(queue="queue1", durable=True,
>                               exclusive=False, auto_delete=False,
>                               callback=on_queue_1_declared)
> def on_queue_1_declared(frame):
>     channel.queue_declare(queue="queue2", durable=True,
>                               exclusive=False, auto_delete=False,
>                               callback=on_queue_2_declared)
> def on_queue_2_declared(frame):
>     channel.queue_declare(queue="queue3", durable=True,
>                               exclusive=False, auto_delete=False,
>                               callback=on_queue_3_declared)
> def on_queue_3_declared(frame):
>     channel.queue_declare(queue="queue4", durable=True,
>                               exclusive=False, auto_delete=False,
>                               callback=on_queue_4_declared)

And so on...

This is not pretty. Any idea on how to achieve this without declaring all
those callbacks ?
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20120319/755da90d/attachment.htm>