RocketMQ5.1.3,消费者故意抛出异常,进行消息消费重试,消费者设置最大重试次数为3,并且创建另一个消费者用于消费死信队列。运行代码发现死信队列消费者消费了三次消息,并没有耗尽所有重试次数才把消息放入死信队列。
生产者代码:
消费者代码:
死信队列消费者代码:
消费者执行情况:
死信队列消费者执行情况:
RocketMQ5.1.3,消费者故意抛出异常,进行消息消费重试,消费者设置最大重试次数为3,并且创建另一个消费者用于消费死信队列。运行代码发现死信队列消费者消费了三次消息,并没有耗尽所有重试次数才把消息放入死信队列。
生产者代码:
消费者代码:
死信队列消费者代码:
消费者执行情况:
死信队列消费者执行情况: