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 7c10c7707d [ISSUE #10154] Rename BrokerConsumeStatsSubCommad to 
BrokerConsumeStatsSubCommand (#10155)
7c10c7707d is described below

commit 7c10c7707dae870320f25b81c79c517daa7f9d98
Author: yx9o <[email protected]>
AuthorDate: Tue Mar 17 10:28:42 2026 +0800

    [ISSUE #10154] Rename BrokerConsumeStatsSubCommad to 
BrokerConsumeStatsSubCommand (#10155)
---
 .../main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java | 4 ++--
 ...ConsumeStatsSubCommad.java => BrokerConsumeStatsSubCommand.java} | 2 +-
 ...tatsSubCommadTest.java => BrokerConsumeStatsSubCommandTest.java} | 6 +++---
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java 
b/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
index d7054933e1..01a6fe3646 100644
--- a/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
+++ b/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
@@ -39,7 +39,7 @@ import 
org.apache.rocketmq.tools.command.auth.ListAclSubCommand;
 import org.apache.rocketmq.tools.command.auth.ListUserSubCommand;
 import org.apache.rocketmq.tools.command.auth.UpdateAclSubCommand;
 import org.apache.rocketmq.tools.command.auth.UpdateUserSubCommand;
-import org.apache.rocketmq.tools.command.broker.BrokerConsumeStatsSubCommad;
+import org.apache.rocketmq.tools.command.broker.BrokerConsumeStatsSubCommand;
 import org.apache.rocketmq.tools.command.broker.BrokerStatusSubCommand;
 import org.apache.rocketmq.tools.command.broker.CleanExpiredCQSubCommand;
 import org.apache.rocketmq.tools.command.broker.CleanUnusedTopicCommand;
@@ -220,7 +220,7 @@ public class MQAdminStartup {
         initCommand(new PrintMessageSubCommand());
         initCommand(new PrintMessageByQueueCommand());
         initCommand(new SendMsgStatusCommand());
-        initCommand(new BrokerConsumeStatsSubCommad());
+        initCommand(new BrokerConsumeStatsSubCommand());
 
         initCommand(new ProducerConnectionSubCommand());
         initCommand(new ConsumerConnectionSubCommand());
diff --git 
a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommad.java
 
b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommand.java
similarity index 99%
rename from 
tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommad.java
rename to 
tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommand.java
index 7658a2139c..0cd39b1cdd 100644
--- 
a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommad.java
+++ 
b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommand.java
@@ -34,7 +34,7 @@ import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
 import org.apache.rocketmq.tools.command.SubCommand;
 import org.apache.rocketmq.tools.command.SubCommandException;
 
-public class BrokerConsumeStatsSubCommad implements SubCommand {
+public class BrokerConsumeStatsSubCommand implements SubCommand {
 
     private DefaultMQAdminExt defaultMQAdminExt;
 
diff --git 
a/tools/src/test/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommadTest.java
 
b/tools/src/test/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommandTest.java
similarity index 95%
rename from 
tools/src/test/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommadTest.java
rename to 
tools/src/test/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommandTest.java
index d7315d0581..35b0f71ea6 100644
--- 
a/tools/src/test/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommadTest.java
+++ 
b/tools/src/test/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommandTest.java
@@ -44,9 +44,9 @@ import static org.mockito.ArgumentMatchers.anyString;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 
-public class BrokerConsumeStatsSubCommadTest {
+public class BrokerConsumeStatsSubCommandTest {
 
-    private static BrokerConsumeStatsSubCommad cmd = new 
BrokerConsumeStatsSubCommad();
+    private static BrokerConsumeStatsSubCommand cmd = new 
BrokerConsumeStatsSubCommand();
 
     private static DefaultMQAdminExt defaultMQAdminExt;
     private static DefaultMQAdminExtImpl defaultMQAdminExtImpl;
@@ -83,7 +83,7 @@ public class BrokerConsumeStatsSubCommadTest {
     @Test
     public void testExecute() throws SubCommandException, 
IllegalAccessException, NoSuchFieldException {
 
-        Field field = 
BrokerConsumeStatsSubCommad.class.getDeclaredField("defaultMQAdminExt");
+        Field field = 
BrokerConsumeStatsSubCommand.class.getDeclaredField("defaultMQAdminExt");
         field.setAccessible(true);
         field.set(cmd, defaultMQAdminExt);
 

Reply via email to