This is an automated email from the ASF dual-hosted git repository. cserwen pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push: new 25b1a0e00e [ISSUE #8490] Fix getMaxReconsumeTimes calculation error in concurrent consumption mode (#8491) 25b1a0e00e is described below commit 25b1a0e00eb771214dc123b10ab3edd5fd8c47a4 Author: yx9o <yangx_s...@163.com> AuthorDate: Mon Aug 5 10:00:50 2024 +0800 [ISSUE #8490] Fix getMaxReconsumeTimes calculation error in concurrent consumption mode (#8491) * [ISSUE #8490] Fix getMaxReconsumeTimes calculation error in concurrent consumption mode --- .../apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java index e66a9825f3..0fef8666cb 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java @@ -653,7 +653,7 @@ public class DefaultMQPushConsumerImpl implements MQConsumerInner { Iterator<MessageExt> iterator = msgListFilterAgain.iterator(); while (iterator.hasNext()) { MessageExt msg = iterator.next(); - if (msg.getReconsumeTimes() > defaultMQPushConsumer.getMaxReconsumeTimes()) { + if (msg.getReconsumeTimes() > getMaxReconsumeTimes()) { iterator.remove(); log.info("Reconsume times has reached {}, so ack msg={}", msg.getReconsumeTimes(), msg); }