opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-31 02:20:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #7570] Add default value for lastPopTimestamp (#7571)

Browse Source
This commit is contained in:
cnScarb
2023-11-17 15:58:14 +08:00
committed by GitHub
parent 651a5ca992
commit 01a2aef96b
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopProcessQueue.java
+1 -1
View File
@@ -26,7 +26,7 @@ public class PopProcessQueue {
private final static long PULL_MAX_IDLE_TIME = Long.parseLong(System.getProperty("rocketmq.client.pull.pullMaxIdleTime", "120000"));
private long lastPopTimestamp;
private long lastPopTimestamp = System.currentTimeMillis();
private AtomicInteger waitAckCounter = new AtomicInteger(0);
private volatile boolean dropped = false;