[rocketmq] branch develop updated: [ISSUE#5015] Fix typo of getAllCongestNum in TimerMessageStore

[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 f1e95cd26 [ISSUE#5015] Fix typo of getAllCongestNum in 
TimerMessageStore
f1e95cd26 is described below

commit f1e95cd266ad82d68158235ca7316722213e3baf
Author: meateggmilk <87265072+meateggm...@users.noreply.github.com>
AuthorDate: Thu Sep 8 09:21:05 2022 +0800

    [ISSUE#5015] Fix typo of getAllCongestNum in TimerMessageStore
    
    Co-authored-by: shizhili <shizh...@cmss.chinamobile.com>
---
 .../org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java    | 2 +-
 .../main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java  | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
index 3af82641a..0ec1c226a 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
@@ -2094,7 +2094,7 @@ public class AdminBrokerProcessor implements 
NettyRequestProcessor {
         if 
(this.brokerController.getMessageStoreConfig().isTimerWheelEnable()) {
             runtimeInfo.put("timerReadBehind", 
String.valueOf(this.brokerController.getMessageStore().getTimerMessageStore().getReadBehind()));
             runtimeInfo.put("timerOffsetBehind", 
String.valueOf(this.brokerController.getMessageStore().getTimerMessageStore().getOffsetBehind()));
-            runtimeInfo.put("timerCongestNum", 
String.valueOf(this.brokerController.getMessageStore().getTimerMessageStore().getALlCongestNum()));
+            runtimeInfo.put("timerCongestNum", 
String.valueOf(this.brokerController.getMessageStore().getTimerMessageStore().getAllCongestNum()));
             runtimeInfo.put("timerEnqueueTps", 
String.valueOf(this.brokerController.getMessageStore().getTimerMessageStore().getEnqueueTps()));
             runtimeInfo.put("timerDequeueTps", 
String.valueOf(this.brokerController.getMessageStore().getTimerMessageStore().getDequeueTps()));
         } else {
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 5be739d35..96335260e 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
@@ -1603,7 +1603,7 @@ public class TimerMessageStore {
                             storeConfig.getBrokerRole(),
                             format(commitReadTimeMs), format(currReadTimeMs), 
format(currWriteTimeMs), getReadBehind(),
                             tmpQueueOffset, maxOffsetInQueue - tmpQueueOffset, 
timerCheckpoint.getMasterTimerQueueOffset() - tmpQueueOffset,
-                            enqueuePutQueue.size(), dequeueGetQueue.size(), 
dequeuePutQueue.size(), getALlCongestNum(), 
format(lastEnqueueButExpiredStoreTime));
+                            enqueuePutQueue.size(), dequeueGetQueue.size(), 
dequeuePutQueue.size(), getAllCongestNum(), 
format(lastEnqueueButExpiredStoreTime));
                     }
                     timerMetrics.persist();
                     waitForRunning(storeConfig.getTimerFlushIntervalMs());
@@ -1615,7 +1615,7 @@ public class TimerMessageStore {
         }
     }
 
-    public long getALlCongestNum() {
+    public long getAllCongestNum() {
         return timerWheel.getAllNum(currReadTimeMs);
     }