This is an automated email from the ASF dual-hosted git repository.
duhengforever 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 ece364a Improve the comment of maxReconsumeTimes
new 35a15b6 Merge pull request #3022 from heihaozi/maxReconsumeTimes
ece364a is described below
commit ece364a14ea679d5eb765ca03fac5886d637feac
Author: CharliePu <[email protected]>
AuthorDate: Mon Jun 21 15:13:19 2021 +0800
Improve the comment of maxReconsumeTimes
---
.../apache/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 9011117..caf166d 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.
- * </p>
+ * 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;