(rocketmq) branch develop updated: [ISSUE #8490] Fix getMaxReconsumeTimes calculation error in concurrent consumption mode (#8491)

[cserwen]

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);
                 }