Spring DefaultMessageListenerContainer - 侦听器未读取 Websphere MQ 上的消息

Question

我正在使用 Spring 3.0 - DefaultMessageListenerContainer 连接到 Websphere 6 MQ。 MQ 上已存在一些消息。当我运行测试时，实现 SessionAwareMessageListener 的侦听器将启动。但 onMessage() 不会被调用。所以问题是已经在队列中的消息没有被读取。

根据文档，autoStartup 默认情况下为 true（并且我没有更改此设置）。根据我的理解，启动时，侦听器应该读取队列中的任何现有消息，并且应该调用 onMessage() 。如果这种理解有误，请告诉我。

以下是配置文件中的片段：

    <bean id="jmsContainer"
        class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="jmsQueueConnectionFactory" />
        <property name="destinationName">
            <value>${queue}</value>
        </property>
        <property name="messageListener" ref="exampleMessageListener" />
        <property name="concurrentConsumers" value="1" />
        <property name="maxConcurrentConsumers" value="1" />
        <property name="idleTaskExecutionLimit" value="4" />
        <property name="maxMessagesPerTask" value="4" />
        <property name="receiveTimeout" value="5000" />
        <property name="recoveryInterval" value="5000" />
        <property name="sessionTransacted" value="true" />
        <property name="transactionManager" ref="jmsTransActionManager" />
    </bean> 

注意：没有错误/异常，测试应用程序启动得很好。

任何解决此问题的指示都会有很大帮助。

谢谢，
RJ

Answer 1

问题已解决。测试类在侦听器获取消息之后但在将消息显示为输出之前终止。因此，第一条消息（最高优先级的消息）从队列中丢失了。

后来，由于我添加了事务管理器，侦听器将消息放回到队列中（显示警告为由于侦听器容器已停止而拒绝接收到的消息）。由于这是一个警告，并且我的记录器处于调试级别，因此我之前错过了这一点。

将 thread.sleep 放入测试类中可确保它运行更长时间，并且侦听器可以按优先级顺序读取队列中的所有消息:)

干杯，
RJ