ppat/storm-rabbitmq

Improve connection config to make it support multi broker address ability (HA)

Closed this issue · 4 comments

linustseng commented

We build a cluster of RabbitMQ and would like to apply its HA feature by modifying some code to meet requirement of rabbitmq java client. Just to replace argument from (host, port) to (address[]) and call different newConnection method by argument list. It will be great if the storm-rabbitmq component would support this feature as well.

Regards.

Please refer to the client API as below
http://www.rabbitmq.com/javadoc/com/rabbitmq/client/ConnectionFactory.html#newConnection(com.rabbitmq.client.Address[])

ppat commented

What we do is put our rabbitmq nodes behind a load balancer (ours is a hardware one but you can very easily set up ha-proxy as well). But if you desire this functionality, feel free to submit a pull request.

linustseng commented

Thanks and I am a newbie to git but I will try to make my first time pull request.

drazzib commented

Hi,

Support for multiple Adress[] in configuration seems to be handled since e5f8410 commit (in 0.6.1 release)

I think we can close this issue.

linustseng commented

Great and sorry that I don't give anything on this issue. Thanks for your help.