java - ActiveMQ:在没有代理的情况下启动消费者

Question

我正在编写一个从队列消费的 JMS 客户端。如果重要的话，我的经纪人是 activemq。

一个要求是，即使代理关闭，客户端也应该启动。在那种情况下，它应该表现得好像队列中没有消息一样，并且一旦代理启动并且消息开始出现相应的行为。

问题是在我的代码中:

connectionFactory = new ActiveMQConnectionFactory(url);
Connection connection = connectionFactory.createConnection();
connection.start()

如果 broker 挂了，它就会卡在 connection.start() 中。虽然我想要的是 connection.start() 静默返回并继续尝试在后台连接并在可以时使用消息，在不能时保持静音。

我怎样才能做到这一点。

Answer 1

使用单独的线程从队列中消费和启动连接。您将需要使用并发队列实现。

线程 1:

• 实例化队列
• 启动线程 2
• 尝试连接/阻止
• 将消息添加到队列

线程 2(或某种池):

• 启动客户端
• 从队列/ block 中读取
• 处理消息