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) {
}