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);