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

lizhimin 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 78575af0b8 [ISSUE #8935] Fix behind metrics unit error in timer 
message store (#8936)
78575af0b8 is described below

commit 78575af0b8ddd409ea71facceb87c144951269ae
Author: Ji Juntao <juntao....@alibaba-inc.com>
AuthorDate: Tue Nov 19 17:35:10 2024 +0800

    [ISSUE #8935] Fix behind metrics unit error in timer message store (#8936)
---
 .../main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java 
b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
index 32075474b9..071b1c0219 100644
--- a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
@@ -1724,7 +1724,7 @@ public class TimerMessageStore {
 
     public long getEnqueueBehindMillis() {
         if (System.currentTimeMillis() - lastEnqueueButExpiredTime < 2000) {
-            return (System.currentTimeMillis() - 
lastEnqueueButExpiredStoreTime) / 1000;
+            return System.currentTimeMillis() - lastEnqueueButExpiredStoreTime;
         }
         return 0;
     }

Reply via email to