From ece364a14ea679d5eb765ca03fac5886d637feac Mon Sep 17 00:00:00 2001 From: CharliePu Date: Mon, 21 Jun 2021 15:13:19 +0800 Subject: [PATCH] Improve the comment of maxReconsumeTimes --- .../rocketmq/client/consumer/DefaultMQPushConsumer.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java index 9011117a..caf166de 100644 --- a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java +++ b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java @@ -236,11 +236,11 @@ public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsume private boolean unitMode = false; /** - * Max re-consume times. -1 means 16 times. - *

+ * Max re-consume times. + * In concurrently mode, -1 means 16; + * In orderly mode, -1 means Integer.MAX_VALUE. * - * If messages are re-consumed more than {@link #maxReconsumeTimes} before success, it's be directed to a deletion - * queue waiting. + * If messages are re-consumed more than {@link #maxReconsumeTimes} before success. */ private int maxReconsumeTimes = -1; -- GitLab