【发布时间】:2021-08-04 22:44:32
【问题描述】:
我正在尝试为使用 IBM JMS 集成代码 ibm-messaging/mq-jms-spring 连接到 MQ 的 JMS 连接编写运行状况检查。我需要检测到 MQ 的连接已丢失。我为 DefaultJmsListenerContainerFactory 挂上了 exceptionListener,它会告诉我何时失去与 MQ 的连接,但我在 JMS 堆栈中找不到任何东西来告诉我何时(重新)建立连接。
调用 ExceptionListener 的代码
@Override
protected void establishSharedConnection() {
try {
super.establishSharedConnection();
}
catch (Exception ex) {
if (ex instanceof JMSException) {
invokeExceptionListener((JMSException) ex);
}
logger.debug("Could not establish shared JMS Connection - " +
"leaving it up to asynchronous invokers to establish a Connection as soon as possible", ex);
}
}
【问题讨论】:
标签: jms ibm-mq spring-jms