Skip to content

Commit 7c10c77

Browse files
authored
[ISSUE #10154] Rename BrokerConsumeStatsSubCommad to BrokerConsumeStatsSubCommand (#10155)
1 parent 7742b7c commit 7c10c77

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@
3939
import org.apache.rocketmq.tools.command.auth.ListUserSubCommand;
4040
import org.apache.rocketmq.tools.command.auth.UpdateAclSubCommand;
4141
import org.apache.rocketmq.tools.command.auth.UpdateUserSubCommand;
42-
import org.apache.rocketmq.tools.command.broker.BrokerConsumeStatsSubCommad;
42+
import org.apache.rocketmq.tools.command.broker.BrokerConsumeStatsSubCommand;
4343
import org.apache.rocketmq.tools.command.broker.BrokerStatusSubCommand;
4444
import org.apache.rocketmq.tools.command.broker.CleanExpiredCQSubCommand;
4545
import org.apache.rocketmq.tools.command.broker.CleanUnusedTopicCommand;
@@ -220,7 +220,7 @@ public static void initCommand() {
220220
initCommand(new PrintMessageSubCommand());
221221
initCommand(new PrintMessageByQueueCommand());
222222
initCommand(new SendMsgStatusCommand());
223-
initCommand(new BrokerConsumeStatsSubCommad());
223+
initCommand(new BrokerConsumeStatsSubCommand());
224224

225225
initCommand(new ProducerConnectionSubCommand());
226226
initCommand(new ConsumerConnectionSubCommand());

tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommad.java renamed to tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommand.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@
3434
import org.apache.rocketmq.tools.command.SubCommand;
3535
import org.apache.rocketmq.tools.command.SubCommandException;
3636

37-
public class BrokerConsumeStatsSubCommad implements SubCommand {
37+
public class BrokerConsumeStatsSubCommand implements SubCommand {
3838

3939
private DefaultMQAdminExt defaultMQAdminExt;
4040

tools/src/test/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommadTest.java renamed to tools/src/test/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommandTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -44,9 +44,9 @@
4444
import static org.mockito.Mockito.mock;
4545
import static org.mockito.Mockito.when;
4646

47-
public class BrokerConsumeStatsSubCommadTest {
47+
public class BrokerConsumeStatsSubCommandTest {
4848

49-
private static BrokerConsumeStatsSubCommad cmd = new BrokerConsumeStatsSubCommad();
49+
private static BrokerConsumeStatsSubCommand cmd = new BrokerConsumeStatsSubCommand();
5050

5151
private static DefaultMQAdminExt defaultMQAdminExt;
5252
private static DefaultMQAdminExtImpl defaultMQAdminExtImpl;
@@ -83,7 +83,7 @@ public static void terminate() {
8383
@Test
8484
public void testExecute() throws SubCommandException, IllegalAccessException, NoSuchFieldException {
8585

86-
Field field = BrokerConsumeStatsSubCommad.class.getDeclaredField("defaultMQAdminExt");
86+
Field field = BrokerConsumeStatsSubCommand.class.getDeclaredField("defaultMQAdminExt");
8787
field.setAccessible(true);
8888
field.set(cmd, defaultMQAdminExt);
8989

0 commit comments

Comments
 (0)