From 71debe63c8d16e6f0ff66e401fb352eb06b293e7 Mon Sep 17 00:00:00 2001 From: cnScarb Date: Fri, 17 Nov 2023 10:30:54 +0800 Subject: [PATCH] [ISSUE #7570] fix: add default value for lastPopTimestamp --- .../apache/rocketmq/client/impl/consumer/PopProcessQueue.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopProcessQueue.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopProcessQueue.java index 3b39b86cc71..50827545b69 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopProcessQueue.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopProcessQueue.java @@ -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;