第 1 步: 使用来自 IBM MQ 的消息并对其进行处理。
第 2 步:如果某些消息处理失败,则将使用 spring Retry 重试一定次数,但如果问题仍然存在,则希望将这些消息移至 Backout Queue。
注意:Spring 重试部分已完成,我需要帮助在重试后将 Poison Message 推送到 Backout Queue。
有人可以帮我吗?
最佳答案
您可以使用 MQ 队列的 BOTHRESH 和 BOQNAME 属性。一旦消息回退计数达到 BOTHRESH 上设置的值,消息就会被 MQ JMS 移至回退队列。有关有害消息处理的更多详细信息是 here .
我对 Spring Retry 不太了解。但如果使用MQ JMS Backout机制,不知是否还需要Spring Retry。
关于java - 使用 Spring 重试进行某些重试后,将有毒消息推送到回退队列 [IBM MQ],我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/68233947/