如何在 ActiveMQ 中自动重新连接 StompJmsConnectionFactory 工厂答案

【问题标题】：How to reconnect automatically StompJmsConnectionFactory factory in ActiveMQ如何在 ActiveMQ 中自动重新连接 StompJmsConnectionFactory 工厂
【发布时间】：2018-02-03 04:39:12
【问题描述】：

正在编写订阅者以监听 AMQ 队列。它正在工作，但我想在 AMQ 重新启动或出现故障时自动重新连接。为此添加了以下代码：-

 StompJmsConnectionFactory factory = new StompJmsConnectionFactory();

            factory.setBrokerURI("failover:tcp://" + host + ":" + port+"?retryInterval=2000&reconnectAttempts=1000");

            connection = factory.createConnection(user, password);

但是这些设置没有按预期工作，为了重现这个场景，我在订阅者运行时停止了 AMQ，我调试了程序，看到它在跨越上面的代码行后遇到了 catch 块（连接被拒绝） .

没有看到任何重新连接尝试。任何想法？我错了。 T 删除了故障转移，我也尝试过，但结果相同

【问题讨论】：

标签： java apache activemq

【解决方案1】：

这看起来您正在使用 StompJMS 客户端，据我所知，该客户端已不再维护，因此我不确定它是否是开始开发项目的最佳选择。

既然您使用的是 Java，为什么不直接使用 ActiveMQ 的原生 Java JMS 客户端呢？它使用 OpenWire 协议并提供比 STOMP 客户端更广泛的功能和更好的支持？

【讨论】：