jakarta-ee - Spring `jms:listener-container` 和 IBM MQ 回退队列

Question

我正在使用 Spring 的 JMS (v. 3.1.2) listener-container 以及来自 WebSphere 7 的 JNDI 设置的 JMS connectionFactory。应用程序正确处理消息(放置/获取)，但在 MQ 队列管理器中设置的撤销设置似乎不起作用。

为了使消息消费失败，我使用带有 setRollbackOnly() 的 spring 事务，它确实增加了属性“Backout count”，因为我可以看到这个数字随着“WebSphere MQ Explorer”而增加指向远程队列。

通读了一些 IBM 文档，它描述了 IBM MQ JMS 客户端 需要将错误消息移至回退队列。 Spring 的 listener-container 似乎没有以支持该行为的方式使用 MQ 客户端。退出计数一直在增加，就好像重新排队命令不起作用一样。

Spring JMS 是否能够使用该功能？是否需要在 listener-container 中设置任何内容才能处理向 IBM MQ 回退队列的移动？

我的配置如下:

<tx:jta-transaction-manager/>
<jee:jndi-lookup id="connectionFactory" 
        jndi-name="java:comp/env/jms/myapp_queuefactory"/>
<jms:listener-container 
        connection-factory="connectionFactory"
        transaction-manager="transactionManager">
    <jms:listener destination="ONEQUEUE" ref="oneQueueListener" />
    <jms:listener destination="ANOTHERQUEUE" ref="anotherQueueListener" />
    <!-- many more -->
<jms:listener-container/>

IBM MQ 队列设置为“Backout Requeue Queue”设置为 ONEQUEUE.BOQ，“Backout Threshold”设置为 5。

我的Spring消息驱动POJO java代码如下:

@Transactional
public class MyQueueMDBean implements javax.jms.MessageListener {
    public void onMessage(javax.jms.Message msg) {
        try {
            // some code that throws some exception ...
        } catch (Exception e) {
            TransactionInterceptor.currentTransactionStatus().setRollbackOnly();    
        }
    }
}

堆栈跟踪错误

消息回滚 5 次后，监听器开始连接失败，作为日志输出:

[org.springframework.jms.listener.DefaultMessageListenerContainer#3-14870] WARN org.springframework.jms.listener.DefaultMessageListenerContainer - 目标“ONEQUEUE”的 JMS 消息监听器调用程序设置失败 - 尝试恢复。原因:MQJMS1079:无法将消息写入死信队列。；嵌套异常是 com.ibm.mq.MQException: MQJE001: Completion Code '2', Reason '2035'。

看起来有些事情正在发生并允许取消消息，或者没有正确检索实际的取消队列，这是意外的，因为 get/puts 工作正常。不过，仍在寻找这是否是一种有效方法的答案。

Answer 1

在回滚次数超过 BackoutThreshold (BOTHRESH) 中定义的数量后，JMS 客户端会将有害消息放入队列的 BackoutRequeueQueue (BOQNAME) 中定义的回退队列。这意味着运行 JMS 应用程序的用户不仅需要访问应用程序队列，还需要访问指定的回退队列。

如果无法访问或未定义回退队列，将尝试使用队列管理器的死信队列(DEADQ 属性)。

未能授予用户 ID +put 对回退队列和/或 DLQ 的访问权限，当有毒消息满足重新排队到退出队列。

2035 将由 JMS 异常报告，并且队列管理器错误日志中将报告确切用户 ID 的确切队列名称的确切缺失权限。

相关阅读

1. Handling poison messages in WebSphere MQ classes for JMS