📌 📄 内容摘要:
NiuRen 在 有没有懂RabbitMQ的老哥帮忙看看哈 中发帖
目的:消息重试3次后将此消息入库并告警
目前的做法:我在发送者端添加了请求头retryCount表示重试次数,初始化为0。在消费者端接收该消息,如果发生异常则重试次数+1,如果重试次数大于3则入库告警。
问题:当发生异常后,重试次数重新接收后仍然为0,并非+1后的数据。
麻烦各位老哥帮忙看看,谢谢啦。
发送者代码:
public String sendEmail(MessageEntity msg) {
// 创建消息处理器,用于设置消息属性
MessagePostProcessor messagePostProcessor = new MessagePostProcessor() {
@Override
public Message postProcessMessage(Message ...
────────── 链接信息 ────────── 🔗 论坛链接: linux.do 📎 访问地址: https://linux.do/t/topic/414481/1 ─────────────────────────────
📢 来源:LINUX DO