Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Implementation of a MultipleQueue class to consume from multiple queues at once #83

Open
pfreixes opened this issue Nov 17, 2015 · 0 comments

Comments

@pfreixes
Copy link

Just as a question before try to implement it and get some feedback from @gmr and users of the Rabbitpy community.

I'm implementing a set of experiments using different AMQP Python drivers such as Pika, Librrabbitmq and so on [1] using a kind of fair scheduling - consuming from many queues - and I would like to get some numbers with the Rabbitpy driver. But I saw that there is no support to consume several queues from one consumer, and now I able to to that only with a N:N correlation between threads/consumers and queues.

In fact the idea behind this trial is just move to a correlation like N:M where the number of threads/consumers as N are always below the number for queues.

To make that Rabbitpy would need a new class - let's say MultipleQueue - that would consume messages from different queues without a strict order, just processing them as they arrive, leaving all of the fairness to the Rabbitmq broker.

Is that interesting ?

Regards,

[1] https://github.com/pfreixes/python-amqp-pycones/tree/master/python_amqp/consume_many_queues

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

2 participants