Websphere 7 Websphere MQ 7.X Spring Integration JMS - Message Listener 停止从队列读取消息

Question

我们正在使用 JMS 和 Spring Integration 读取来自 Websphere MQ 的消息。

<task:executor id="demoMessageReceiverChannelTE" pool-size="1-3" queue-capacity="5" keep-alive="1" rejection-policy="CALLER_RUNS"/>

<int:channel id="demoMessageReceiverChannel">
    <int:dispatcher task-executor="demoMessageReceiverChannelTE"/>
    <int:interceptors>
        <int:ref bean="messageReceiverInterceptor" />
    </int:interceptors>
</int:channel>

<jms:message-driven-channel-adapter
id="demoMesssageReceiverAdapter" channel="demoMessageReceiverChannel"
connection-factory="srcJmsConnectionFactory" destination="srcReceiverQueue"
error-channel="errorChannel" message-converter="demoIncomingMessageConverter"
transaction-manager="srcJmsTransactionManager" send-timeout="65000"
header-mapper="demoJmsHeaders" />

还有另一个系统，它将消息放在此队列上。（超出我们的范围）

我们可以一次有 2000 条消息在队列中被读取。

有时，消息侦听器会停止从队列读取消息，当我尝试解决此问题时，它给出了队列中有一些未提交消息的原因，侦听器尝试读取该消息，将无法进一步处理并挂起本身。

与从队列中手动删除该消息一样，它会完美地处理其他消息。

那么如何跳过这些未提交的消息，以便系统可以继续下一条消息呢？

Answer 1

听起来像是一个经典的未经处理的毒物信息问题。当应用读取它无法处理的消息时，该消息将回退到队列。然后再次读回它，因为它位于队列的顶部。这会导致消息显示为处于同步点状态，直到最后侦听器放弃并停止。

有时问题出在应用中，是应用显式调用 ROLLBACK。有时，尽管发生回滚，但应用程序甚至会看到该消息。例如，如果消息无法转换为本地代码页，或其他低级错误。

如果发生这种情况，答案是定义一个撤销队列，然后更改输入队列以指向它。例如，如果输入队列称为 SRC。接收器。队列 您可以使用 runmqsc 在 QMgr 上执行以下操作：

DEFINE QL(SRC.RECEIVER.QUEUE.BKOUT)
ALTER QL(SRC.RECEIVER.QUEUE) BOQNAME(SRC.RECEIVER.QUEUE.BKOUT) BOTHRESH(15)

如果问题确实是有害消息，则问题消息将在回退队列中显示为未提交的消息。一旦应用针对源队列发出下一个 COMMIT，撤销消息将在撤销队列中可见。如果没有其他消息到达源队列，则病毒消息将在回退队列中保持未提交状态，或者在应用或 QMgr 调用 ROLLBACK 时可能还原到源队列。

回退队列的设置很简单，应该是标准做法，所以我建议不管它是否能解决问题。请参阅信息中心中的处理 WebSphere MQ 类中的 JMS 有害消息。