我正在使用CachingConnectionFactory的setAddresses方法来处理多个集群。
connection = new CachingConnectionFactory();connection.setAddresses("rabbit1:5672,rabbit2:5672")。
当我关闭集群rabbit1时,它会在下一个集群rabbit2上启动。
我的问题是有一些配置,能够返回到第一个集群rabbit1,我已经试过了,但我发现如何解决它。
谢谢你
连接工厂有一个重置连接的方法。
factory.resetConnection()
下一次打开将从头开始(除非 shuffleAddresses
已设置为 true
).