Jms 网关无法刷新 MQ 连接

Question

我有一个入站网关，它正在侦听 MQ 的消息。每当 MQ 服务器被买下时。我断开了连接，在日志中我看到我的入站网关尝试每 5 秒刷新一次连接。但是一旦 MQ 服务器启动，我仍然会在日志中看到相同的错误。如果我遗漏了配置中的任何信息，或者是否有任何需要在 MQ 服务器上完成的事情，请告诉我。

Spring 配置

<bean id="cachingConnectionFactory1" class="org.springframework.jms.connection.CachingConnectionFactory"> 
    <property name="targetConnectionFactory" ref="mqConnectionFactory1"/> 
    <property name="reconnectOnException" value="true"/>
</bean>

<bean id="mqConnectionFactory1" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter"> 
    <property name="targetConnectionFactory"> 
        <bean class="com.ibm.mq.jms.MQQueueConnectionFactory"> 
            <property name="hostName" value="${mq.hostname.1}"/> 
            <property name="port" value="${mq.port}"/> 
            <property name="queueManager" value="${mq.queuemanager.1}"/> 
            <property name="transportType" value="${mq.transporttype}"/>
            <property name="channel" value="${mq.channel}"/>
        </bean> 
    </property> 
    <property name="username" value="${mq.username}"/>
</bean>

<int-jms:message-driven-channel-adapter 
        id="mqEnterpriseRequestAdapter1" 
        connection-factory="cachingConnectionFactory1" 
        destination="xyzQueue"
        concurrent-consumers="2"
        max-concurrent-consumers="5"
        cache-level="5" 
        idle-consumer-limit="5"
        max-messages-per-task="2"
        channel="xyzReceive"/>

错误日志：

[2015-09-19 01:52:56,267]  WARN [org.springframework.jms.listener.DefaultMessageListenerContainer#4-494492] (DefaultMessageListenerContainer.java:842) - Setup of JMS message listener invoker failed for destination 'queue:///queuename' - trying to recover. Cause: MQJMS2002: failed to get message from MQ queue; nested exception is com.ibm.mq.MQException: MQJE001: Completion Code 2, Reason 2019
[2015-09-19 01:52:51,292]  WARN [org.springframework.jms.listener.DefaultMessageListenerContainer#4-494037] (DefaultMessageListenerContainer.java:842) - Setup of JMS message listener invoker failed for destination 'queue:///queuename' - trying to recover. Cause: MQJMS2002: failed to get message from MQ queue; nested exception is com.ibm.mq.MQException: MQJE001: Completion Code 2, Reason 2019
[2015-09-19 01:52:51,263]  WARN [org.springframework.jms.listener.DefaultMessageListenerContainer#4-494488] (DefaultMessageListenerContainer.java:842) - Setup of JMS message listener invoker failed for destination 'queue:///queuename' - trying to recover. Cause: MQJMS2002: failed to get message from MQ queue; nested exception is com.ibm.mq.MQException: MQJE001: Completion Code 2, Reason 2019
[2015-09-19 01:52:46,291]  WARN [org.springframework.jms.listener.DefaultMessageListenerContainer#4-494033] (DefaultMessageListenerContainer.java:842) - Setup of JMS message listener invoker failed for destination 'queue:///queuename' - trying to recover. Cause: MQJMS2002: failed to get message from MQ queue; nested exception is com.ibm.mq.MQException: MQJE001: Completion Code 2, Reason 2019
[2015-09-19 01:52:46,262]  WARN [org.springframework.jms.listener.DefaultMessageListenerContainer#4-494485] (DefaultMessageListenerContainer.java:842) - Setup of JMS message listener invoker failed for destination 'queue:///queuename' - trying to recover. Cause: MQJMS2002: failed to get message from MQ queue; nested exception is com.ibm.mq.MQException: MQJE001: Completion Code 2, Reason 2019

Answer 1

我通过谷歌搜索找到了你问题的答案MQJE001: Completion Code 2, Reason 2019

答案是on IBM's support site。

Reason code 2019 usually occurs after a connection broken error (reason code 2009) occurs. You would see a JMSException with reason code 2009 preceding reason code 2019 in the SystemOut.log.

Reason code 2009 indicates that the connection to the MQ queue manager is no longer valid, usually due to a network or firewall issue.

Reason code 2019 errors will occur when invalid connections remain in the connection pool after the reason code 2009 error occurs. The next time that the application tries to use one of these connections, the reason code 2019 occurs.

Answer 2

按照下面post解决，修改后配置发生变化 http://forum.spring.io/forum/spring-projects/integration/jms/89532-defaultmessagelistenercontainer-cachingconnectionfactory-tomcat-and-websphere-mq

<bean id="mqContainer1" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="connectionFactory" ref="cachingConnectionFactory1" />
    <property name="exceptionListener" ref="cachingConnectionFactory1" />
    <property name="destinationName" value="${mq.requestqueue}" />
    <property name="maxConcurrentConsumers" value="x"/>
    <property name="concurrentConsumers" value="x"/>
    <property name="maxMessagesPerTask" value="x"/>
    <property name="idleConsumerLimit" value="x"/>
</bean>

<int-jms:message-driven-channel-adapter 
        id="mqEnterpriseRequestAdapter1" 
        container="cbatsMqContainer1"
        channel="mqMessageReceive"/>

Jms 网关无法刷新 MQ 连接

Jms Gateway Unable to refresh MQ connection

spring-integration