jms - JMS 和 ActiveMQ，如何在断开连接时接收通知？

Question

我正在使用 JMS 与 ActiveMQ 对话。我不得不为 ActiveMQ 禁用故障转移，因为我需要自己处理它。

所以我没有使用：故障转移//tcp//localhost:61616，而是使用：tcp//localhost:61616。

如果我关闭 ActiveMQ 服务器并尝试发送消息，我将收到异常。javax.jms.IllegalStateException：会话已关闭

但是当与服务器的连接尽快丢失时，如何通知我？

原因，我没有使用 ActiveMQ 的故障转移，因为在生产中它应该是 MQSeries。

谢谢

Answer 1

我不确定，但TransportListener可以帮助你。

这是使用它的示例，

connection = new ActiveMQConnectionFactory(brokerUrl).createConnection();
ActiveMQConnection cc = (ActiveMQConnection)connection;
cc.addTransportListener(new YourTransportListener());  

希望这可以帮助你。