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

Support for RabbitMQ Clusters #33

Open
MarcDufresne opened this issue Sep 1, 2016 · 2 comments
Open

Support for RabbitMQ Clusters #33

MarcDufresne opened this issue Sep 1, 2016 · 2 comments

Comments

@MarcDufresne
Copy link

Hi, I recently stumbled upon this library and replaced my kombu setup with it. So far it works great and is faster than kombu.

Now the only problem I'm having is that amqpy doesn't seem to support the amqp connection string (e.g.: amqp://<user>:<pass>@<host>:<port>) when establishing a connection. Moreover, it looks like there is no way of connecting to multiple servers in a cluster. The way I do it with kombu is by simply providing amqp://<user>:<pass>@<host1>:<port1>;amqp://<user>:<pass>@<host2>:<port2>;amqp://<user>:<pass>@<host3>:<port3> as the connection parameter.

Maybe I missed something in the code, you can tell me if I'm wrong. It's the only thing right now keeping me from using this library for production purpose, which is a shame considering how well it works.

@veegee
Copy link
Owner

veegee commented Sep 2, 2016

You're right, these two features are not supported. I would like to add support for this, but having difficulty finding the time for it at the moment.

The connection string is easy enough to implement. As far as the clusters go, I'll need to do a bit of research. I was also in the middle of redoing the underlying concurrency mechanism.

@MarcDufresne
Copy link
Author

I just opened a pull request #34 to add support for the AMQP connection string, tell me what you think about it.

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

No branches or pull requests

2 participants