(rocketmq) branch develop updated: [ISSUE #7570] Add default value for lastPopTimestamp (#7571)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong 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 01a2aef96b [ISSUE #7570] Add default value for lastPopTimestamp (#7571)
01a2aef96b is described below

commit 01a2aef96bdfb17c5f82415141ef421efb4e3bc7
Author: cnScarb <jjhfe...@163.com>
AuthorDate: Fri Nov 17 15:58:14 2023 +0800

    [ISSUE #7570] Add default value for lastPopTimestamp (#7571)
---
 .../java/org/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 3b39b86cc7..50827545b6 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;