java - 使用 Spring 重试进行某些重试后,将有毒消息推送到回退队列 [IBM MQ]

标签 java spring spring-boot ibm-mq

第 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/

相关文章:

java - Springboot中json解析错误

java - 我可以使用什么文件格式直接从程序输出格式化的文本文件,而无需标记太复杂?

java - JAVA输入空字符串的方法

java - Weblogic 9.2.1 上的 RichFaces

java - 如何使用 docx4j 将多行添加到表中

java - 如何在 Spring JDBC 中启用 sql 查询控制台日志记录

java - Spring MVC - DispatcherServlet 通过注释

java - 在 Spring Boot 中使用 Java 配置在 bean 定义之外为 bean 别名

java - 如何将 HttpServletResponse 响应获取到 Spring Boot 的 REST Controller 中?

java - 忽略来自 Spring Bean 后处理器的依赖库的 @Value 字段处理