This is an automated email from the ASF dual-hosted git repository.

RongtongJin 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 2af604f3af [ISSUE #10593] Rename CLusterSendMsgRTCommand to 
ClusterSendMsgRTCommand (#10594)
2af604f3af is described below

commit 2af604f3afc3a14376fc3e980a045c306ffef9fe
Author: yx9o <[email protected]>
AuthorDate: Mon Jul 6 10:27:33 2026 +0800

    [ISSUE #10593] Rename CLusterSendMsgRTCommand to ClusterSendMsgRTCommand 
(#10594)
    
    * [ISSUE #10593] Rename CLusterSendMsgRTCommand to ClusterSendMsgRTCommand
    
    * Update
---
 .../main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java   | 4 ++--
 .../{CLusterSendMsgRTCommand.java => ClusterSendMsgRTCommand.java}    | 2 +-
 2 files changed, 3 insertions(+), 3 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 01a6fe3646..14df64632b 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
@@ -54,7 +54,7 @@ import 
org.apache.rocketmq.tools.command.broker.SendMsgStatusCommand;
 import org.apache.rocketmq.tools.command.broker.SwitchTimerEngineSubCommand;
 import org.apache.rocketmq.tools.command.broker.UpdateBrokerConfigSubCommand;
 import 
org.apache.rocketmq.tools.command.broker.UpdateColdDataFlowCtrGroupConfigSubCommand;
-import org.apache.rocketmq.tools.command.cluster.CLusterSendMsgRTCommand;
+import org.apache.rocketmq.tools.command.cluster.ClusterSendMsgRTCommand;
 import org.apache.rocketmq.tools.command.cluster.ClusterListSubCommand;
 import 
org.apache.rocketmq.tools.command.connection.ConsumerConnectionSubCommand;
 import 
org.apache.rocketmq.tools.command.connection.ProducerConnectionSubCommand;
@@ -252,7 +252,7 @@ public class MQAdminStartup {
         initCommand(new AllocateMQSubCommand());
 
         initCommand(new CheckMsgSendRTCommand());
-        initCommand(new CLusterSendMsgRTCommand());
+        initCommand(new ClusterSendMsgRTCommand());
 
         initCommand(new GetNamesrvConfigCommand());
         initCommand(new UpdateNamesrvConfigCommand());
diff --git 
a/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java
 
b/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterSendMsgRTCommand.java
similarity index 99%
rename from 
tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java
rename to 
tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterSendMsgRTCommand.java
index d755e9e5d8..caeb29e26c 100644
--- 
a/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java
+++ 
b/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterSendMsgRTCommand.java
@@ -36,7 +36,7 @@ import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
 import org.apache.rocketmq.tools.command.SubCommand;
 import org.apache.rocketmq.tools.command.SubCommandException;
 
-public class CLusterSendMsgRTCommand implements SubCommand {
+public class ClusterSendMsgRTCommand implements SubCommand {
 
     public static void main(String[] args) {
     }

Reply via email to