[ISSUE apache#8148] Fix variable typo

Jianing-Xu · May 16, 2024 · c00fac3 · c00fac3
1 parent 8150e13
commit c00fac3
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -408,7 +408,7 @@ public BrokerController(
             this.brokerConfig, this.nettyServerConfig, this.nettyClientConfig, this.messageStoreConfig
         );
 
-        this.brokerStatsManager.setProduerStateGetter(new BrokerStatsManager.StateGetter() {
+        this.brokerStatsManager.setProducerStateGetter(new BrokerStatsManager.StateGetter() {
             @Override
             public boolean online(String instanceId, String group, String topic) {
                 if (getTopicConfigManager().getTopicConfigTable().containsKey(NamespaceUtil.wrapNamespace(instanceId, topic))) {

diff --git a/store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java b/store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
@@ -142,7 +142,7 @@ public class BrokerStatsManager {
     private MomentStatsItemSet momentStatsItemSetFallTime;
 
     private final StatisticsManager accountStatManager = new StatisticsManager();
-    private StateGetter produerStateGetter;
+    private StateGetter producerStateGetter;
     private StateGetter consumerStateGetter;
 
     private BrokerConfig brokerConfig;
@@ -270,7 +270,7 @@ public boolean online(StatisticsItem item) {
 
                 String kind = item.getStatKind();
                 if (ACCOUNT_SEND.equals(kind) || ACCOUNT_SEND_REJ.equals(kind)) {
-                    return produerStateGetter.online(instanceId, group, topic);
+                    return producerStateGetter.online(instanceId, group, topic);
                 } else if (ACCOUNT_RCV.equals(kind) || ACCOUNT_SEND_BACK.equals(kind) || ACCOUNT_SEND_BACK_TO_DLQ.equals(kind) || ACCOUNT_REV_REJ.equals(kind)) {
                     return consumerStateGetter.online(instanceId, group, topic);
                 }
@@ -296,12 +296,12 @@ public MomentStatsItemSet getMomentStatsItemSetFallTime() {
         return momentStatsItemSetFallTime;
     }
 
-    public StateGetter getProduerStateGetter() {
-        return produerStateGetter;
+    public StateGetter getProducerStateGetter() {
+        return producerStateGetter;
     }
 
-    public void setProduerStateGetter(StateGetter produerStateGetter) {
-        this.produerStateGetter = produerStateGetter;
+    public void setProducerStateGetter(StateGetter producerStateGetter) {
+        this.producerStateGetter = producerStateGetter;
     }
 
     public StateGetter getConsumerStateGetter() {