From c94f8e14a9bb5d604734870f995a4a053161fc27 Mon Sep 17 00:00:00 2001 From: yx9o Date: Wed, 4 Mar 2026 23:56:42 +0800 Subject: [PATCH] [ISSUE #10154] Rename BrokerConsumeStatsSubCommad to BrokerConsumeStatsSubCommand --- .../org/apache/rocketmq/tools/command/MQAdminStartup.java | 4 ++-- ...tatsSubCommad.java => BrokerConsumeStatsSubCommand.java} | 2 +- ...ommadTest.java => BrokerConsumeStatsSubCommandTest.java} | 6 +++--- 3 files changed, 6 insertions(+), 6 deletions(-) rename tools/src/main/java/org/apache/rocketmq/tools/command/broker/{BrokerConsumeStatsSubCommad.java => BrokerConsumeStatsSubCommand.java} (99%) rename tools/src/test/java/org/apache/rocketmq/tools/command/broker/{BrokerConsumeStatsSubCommadTest.java => BrokerConsumeStatsSubCommandTest.java} (95%) 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 d7054933e10..01a6fe36468 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.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 static void initCommand() { 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 7658a2139c5..0cd39b1cdd0 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.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 d7315d0581f..35b0f71ea68 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.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 static void terminate() { @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);