java - Websphere MQ 消息不会回退到输入队列

Question

Websphere MQ 中有一条消息。已阅读该消息，我正在尝试将消息退回到输入队列。尚未达到重试阈值。发生异常时MQ消息是否自动放入Input Q？这是我的代码:

MQQueueManager qm = new MQQueueManager("");
MQQueue q = qm.accessQueue("");
MQMessage message = new MQMessage();
q.get(message);
System.out.println("Retry Count"+ message.backoutCount);
throw new NullPointerException;

上面的代码会再次将消息放入Input Queue吗？在这种情况下，它不会将消息放回输入队列。消息丢失。

Answer 1

只有当您的消息最初是事务的一部分时，才可以撤消该消息。您的代码不使用事务。

查看 MQGMO 选项 MQGMO_SYNCPOINT 和 MQGMO_SYNCPOINT_IF_PERSISTENT(在下面两个链接中搜索字符串 MQGMO_SYNCPOINT)。

MQ Java Classes CMQC constants

MQ API description of MQGMO_SYNCPOINT - applicable to all languages

还有 MQQueueManager 上的 commit() 和 backout() 方法:

MQQueueManager class

并建议您阅读此交易的通用说明

Committing and backing out units of work