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