如何接收 JMS 断开连接的通知？

发布于 2024-11-18 21:49:20 字数 397 浏览 1 评论 0原文

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

因此，我没有使用 failover//tcp//localhost:61616，而是使用 tcp//localhost:61616。

如果我关闭 ActiveMQ 服务器并尝试发送消息，我将收到异常。

javax.jms.IllegalStateException: The Session is closed

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

我没有使用 ActiveMQ 的故障转移的原因是因为在生产中我将使用 MQSeries。因此，我需要一种纯 JMS 且不特定于任何特定实现的方法。

原文

I'm using JMS to talk to ActiveMQ. I had to disable failover for ActiveMQ because I need to handle it myself.

So instead of using failover//tcp//localhost:61616 I used tcp//localhost:61616.

If I close ActiveMQ server and try to send a message, I'll receive an exception.

javax.jms.IllegalStateException: The Session is closed

But how can I be notified when the connection with the server is lost ASAP?

The reason I'm not using the ActiveMQ's failover is because in production I will be using MQSeries. Therefore, I need a method that's pure JMS and not specific to any particular implementation.

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

_失温 2024-11-25 21:49:20

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

这是一个使用示例，

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

希望对您有所帮助。

I am not sure but TransportListener can help you.

Here is a sample of using it,

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

Hope this may help you.

回复收藏 0 原文

~没有更多了~