mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-24 16:04:00 +08:00
Improve the comment of maxReconsumeTimes
This commit is contained in:
@@ -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;
|
||||
|
||||
|
||||
Reference in New Issue
Block a user