Jan 18th, 2012, 09:08 PM
Dynamic bindings and failover RabbitMq
We have a need to dynamically add and remove bindings while our application is running. We currently use the AmqpAdmin to do this which works pretty well at startup.
The problem we are having is if we lose connection to the broker, our bindings are lost as well. I see that the recommended way to do bindings is to declare them as beans which will deal with this, but because of our requirements I was looking for some type of listener we could attach to be triggered upon reconnect. Any suggestions?
Jan 21st, 2012, 02:30 AM
AmqpAdmin is actually implemented as a listener. You could borrow from there and register the listener with the Spring ConnectionFactory.
Tags for this Thread