commit | 6185423e0373c63be5b4fe459ad9e2306893ca1f | [log] [tgz] |
---|---|---|
author | wenfeng <sxian.wang@gmail.com> | Fri Jul 16 17:55:34 2021 +0800 |
committer | GitHub <noreply@github.com> | Fri Jul 16 17:55:34 2021 +0800 |
tree | f86fe997ffdcf3c939138d06617e25e14005a721 | |
parent | 8ebc953f7bef0e20173c90a8117a95712eebec83 [diff] | |
parent | eb75de9a3cb47581f1016593f79be2abfe129521 [diff] |
Merge pull request #379 from heihaozi/maxReconsumeTimes [ISSUE #378]Improve the comment of maxReconsumeTimes
diff --git a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/annotation/RocketMQMessageListener.java b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/annotation/RocketMQMessageListener.java index bdf2ca0..e5f729f 100644 --- a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/annotation/RocketMQMessageListener.java +++ b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/annotation/RocketMQMessageListener.java
@@ -76,7 +76,10 @@ int consumeThreadMax() default 64; /** - * 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. */ int maxReconsumeTimes() default -1;