How to connect to master / slave rabbitmq

[avyaktha]

We have have two rabbit mq , one acting as a failover. Currently the way i connect is i create two separate connectionFactories

<bean id="listener1" class="org.springframework.amqp.rabbit.listener.Si mpleMessageListenerContainer" init-method="doStart">
<property name="connectionFactory" ref="host1ConnectionFactory"/>
<property name="queueName" value="${tdb.rabbit.queue_name}"/>
<property name="messageListener" ref="listenerAdapter"/>
</bean>

<bean id="listener2" class="org.springframework.amqp.rabbit.listener.Si mpleMessageListenerContainer" init-method="doStart">
<property name="connectionFactory" ref="host2ConnectionFactory"/>
<property name="queueName" value="${tdb.rabbit.queue_name}"/>
<property name="messageListener" ref="listenerAdapter"/>
</bean>

Like this.

Is there a way to get around this and just use one listener?

[Mark Fisher]

Do either of these planned issues seem relevant?:
https://jira.springsource.org/browse/AMQP-44
https://jira.springsource.org/browse/AMQP-45

[avyaktha]

https://jira.springsource.org/browse/AMQP-45

more looks like the related feature. I looked at AbstractRoutingDataSource , I was more looking at an interface like this

new XXXConnectionFactory(List<ServerAddress>)

address could be host,port,username,password,vhost

The factory/connection should internally deal with failover. If address1 is down the request should always be delegated to the other addresses


https://jira.springsource.org/browse/AMQP-44 is also a feature that I will definitely wait for


Thanks,
Suresh

[Mark Fisher]

Have you looked into clustering of the RabbitMQ broker itself?

[avyaktha]

I am just a newbie to rabbitmq the person who set the exchange up says that it doesn't support VIP so was told to connect to two seperate servers

Suresh