gpt4 book ai didi

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

转载 作者:行者123 更新时间:2023-12-02 01:44:59 31 4
gpt4 key购买 nike

我正在使用 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 工作正常。不过,仍在寻找这是否是一种有效方法的答案。

最佳答案

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

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

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

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

相关阅读

  1. Handling poison messages in WebSphere MQ classes for JMS

关于jakarta-ee - Spring `jms:listener-container` 和 IBM MQ 回退队列,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/26174028/

31 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com