Skip to content

Commit

Permalink
[ISSUE apache#8490] Fix getMaxReconsumeTimes calculation error in con…
Browse files Browse the repository at this point in the history
…current consumption mode (apache#8491)

* [ISSUE apache#8490] Fix getMaxReconsumeTimes calculation error in concurrent consumption mode
  • Loading branch information
yx9o authored Aug 5, 2024
1 parent d94d075 commit 25b1a0e
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -653,7 +653,7 @@ private PopResult processPopResult(final PopResult popResult, final Subscription
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);
}
Expand Down

0 comments on commit 25b1a0e

Please sign in to comment.