This is an automated email from the ASF dual-hosted git repository. jinrongtong 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 fec1414814 [ISSUE #7166] Optimize the display format of admin (#7210) fec1414814 is described below commit fec141481496c53a0db398367006c34264662d18 Author: yx9o <yangx_s...@163.com> AuthorDate: Wed Aug 23 08:22:34 2023 +0800 [ISSUE #7166] Optimize the display format of admin (#7210) --- .../src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java | 2 +- .../tools/command/acl/ClusterAclConfigVersionListSubCommand.java | 2 +- .../apache/rocketmq/tools/command/acl/DeleteAccessConfigSubCommand.java | 2 +- .../apache/rocketmq/tools/command/acl/GetAccessConfigSubCommand.java | 2 +- .../apache/rocketmq/tools/command/acl/UpdateAccessConfigSubCommand.java | 2 +- .../rocketmq/tools/command/acl/UpdateGlobalWhiteAddrSubCommand.java | 2 +- .../rocketmq/tools/command/broker/BrokerConsumeStatsSubCommad.java | 2 +- .../apache/rocketmq/tools/command/broker/BrokerStatusSubCommand.java | 2 +- .../rocketmq/tools/command/broker/CommitLogSetReadAheadSubCommand.java | 2 +- .../rocketmq/tools/command/broker/DeleteExpiredCommitLogSubCommand.java | 2 +- .../apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java | 2 +- .../apache/rocketmq/tools/command/broker/GetBrokerEpochSubCommand.java | 2 +- .../rocketmq/tools/command/broker/GetColdDataFlowCtrInfoSubCommand.java | 2 +- .../command/broker/RemoveColdDataFlowCtrGroupConfigSubCommand.java | 2 +- .../rocketmq/tools/command/broker/ResetMasterFlushOffsetSubCommand.java | 2 +- .../rocketmq/tools/command/broker/UpdateBrokerConfigSubCommand.java | 2 +- .../command/broker/UpdateColdDataFlowCtrGroupConfigSubCommand.java | 2 +- .../apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java | 2 +- .../apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java | 2 +- .../rocketmq/tools/command/connection/ConsumerConnectionSubCommand.java | 2 +- .../rocketmq/tools/command/connection/ProducerConnectionSubCommand.java | 2 +- .../rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java | 2 +- .../rocketmq/tools/command/consumer/GetConsumerConfigSubCommand.java | 2 +- .../rocketmq/tools/command/consumer/StartMonitoringSubCommand.java | 2 +- .../rocketmq/tools/command/consumer/UpdateSubGroupSubCommand.java | 2 +- .../apache/rocketmq/tools/command/container/AddBrokerSubCommand.java | 2 +- .../apache/rocketmq/tools/command/container/RemoveBrokerSubCommand.java | 2 +- .../tools/command/controller/CleanControllerBrokerMetaSubCommand.java | 2 +- .../tools/command/controller/GetControllerMetaDataSubCommand.java | 2 +- .../rocketmq/tools/command/controller/ReElectMasterSubCommand.java | 2 +- .../org/apache/rocketmq/tools/command/export/ExportConfigsCommand.java | 2 +- .../org/apache/rocketmq/tools/command/export/ExportMetadataCommand.java | 2 +- .../org/apache/rocketmq/tools/command/export/ExportMetricsCommand.java | 2 +- .../org/apache/rocketmq/tools/command/ha/GetSyncStateSetSubCommand.java | 2 +- .../java/org/apache/rocketmq/tools/command/ha/HAStatusSubCommand.java | 2 +- .../apache/rocketmq/tools/command/message/CheckMsgSendRTCommand.java | 2 +- .../apache/rocketmq/tools/command/message/ConsumeMessageCommand.java | 2 +- .../apache/rocketmq/tools/command/message/DumpCompactionLogCommand.java | 2 +- .../rocketmq/tools/command/message/PrintMessageByQueueCommand.java | 2 +- .../apache/rocketmq/tools/command/message/PrintMessageSubCommand.java | 2 +- .../apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java | 2 +- .../apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java | 2 +- .../rocketmq/tools/command/message/QueryMsgByOffsetSubCommand.java | 2 +- .../rocketmq/tools/command/message/QueryMsgByUniqueKeySubCommand.java | 2 +- .../rocketmq/tools/command/message/QueryMsgTraceByIdSubCommand.java | 2 +- .../org/apache/rocketmq/tools/command/message/SendMessageCommand.java | 2 +- .../apache/rocketmq/tools/command/namesrv/AddWritePermSubCommand.java | 2 +- .../apache/rocketmq/tools/command/namesrv/WipeWritePermSubCommand.java | 2 +- .../rocketmq/tools/command/offset/SkipAccumulationSubCommand.java | 2 +- .../org/apache/rocketmq/tools/command/stats/StatsAllSubCommand.java | 2 +- .../org/apache/rocketmq/tools/command/topic/AllocateMQSubCommand.java | 2 +- .../org/apache/rocketmq/tools/command/topic/TopicClusterSubCommand.java | 2 +- .../org/apache/rocketmq/tools/command/topic/TopicListSubCommand.java | 2 +- .../org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java | 2 +- .../org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java | 2 +- .../org/apache/rocketmq/tools/command/topic/UpdateOrderConfCommand.java | 2 +- .../rocketmq/tools/command/topic/UpdateStaticTopicSubCommand.java | 2 +- .../apache/rocketmq/tools/command/topic/UpdateTopicPermSubCommand.java | 2 +- .../org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java | 2 +- 59 files changed, 59 insertions(+), 59 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 0c2618e91c..890125ca0b 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 @@ -278,7 +278,7 @@ public class MQAdminStartup { System.out.printf("The most commonly used mqadmin commands are:%n"); for (SubCommand cmd : SUB_COMMANDS) { - System.out.printf(" %-25s %s%n", cmd.commandName(), cmd.commandDesc()); + System.out.printf(" %-35s %s%n", cmd.commandName(), cmd.commandDesc()); } System.out.printf("%nSee 'mqadmin help <command>' for more information on a specific command.%n"); diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/acl/ClusterAclConfigVersionListSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/acl/ClusterAclConfigVersionListSubCommand.java index f8a00b1e0b..26ed028fb3 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/acl/ClusterAclConfigVersionListSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/acl/ClusterAclConfigVersionListSubCommand.java @@ -47,7 +47,7 @@ public class ClusterAclConfigVersionListSubCommand implements SubCommand { @Override public String commandDesc() { - return "List all of acl config version information in cluster"; + return "List all of acl config version information in cluster."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/acl/DeleteAccessConfigSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/acl/DeleteAccessConfigSubCommand.java index fd3a92fffa..a7f3d295a7 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/acl/DeleteAccessConfigSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/acl/DeleteAccessConfigSubCommand.java @@ -42,7 +42,7 @@ public class DeleteAccessConfigSubCommand implements SubCommand { @Override public String commandDesc() { - return "Delete Acl Config Account in broker"; + return "Delete Acl Config Account in broker."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/acl/GetAccessConfigSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/acl/GetAccessConfigSubCommand.java index 25844d6a19..f1c9a14969 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/acl/GetAccessConfigSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/acl/GetAccessConfigSubCommand.java @@ -49,7 +49,7 @@ public class GetAccessConfigSubCommand implements SubCommand { @Override public String commandDesc() { - return "List all of acl config information in cluster"; + return "List all of acl config information in cluster."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/acl/UpdateAccessConfigSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/acl/UpdateAccessConfigSubCommand.java index 3be40daa17..d8a06f92d1 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/acl/UpdateAccessConfigSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/acl/UpdateAccessConfigSubCommand.java @@ -40,7 +40,7 @@ public class UpdateAccessConfigSubCommand implements SubCommand { @Override public String commandDesc() { - return "Update acl config yaml file in broker"; + return "Update acl config yaml file in broker."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/acl/UpdateGlobalWhiteAddrSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/acl/UpdateGlobalWhiteAddrSubCommand.java index ff662b5069..9dacf1fae6 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/acl/UpdateGlobalWhiteAddrSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/acl/UpdateGlobalWhiteAddrSubCommand.java @@ -37,7 +37,7 @@ public class UpdateGlobalWhiteAddrSubCommand implements SubCommand { @Override public String commandDesc() { - return "Update global white address for acl Config File in broker"; + return "Update global white address for acl Config File in broker."; } @Override 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/BrokerConsumeStatsSubCommad.java index 3f2f906730..7658a2139c 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/BrokerConsumeStatsSubCommad.java @@ -61,7 +61,7 @@ public class BrokerConsumeStatsSubCommad implements SubCommand { @Override public String commandDesc() { - return "Fetch broker consume stats data"; + return "Fetch broker consume stats data."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerStatusSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerStatusSubCommand.java index 830ff3425e..ce934f547b 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerStatusSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerStatusSubCommand.java @@ -44,7 +44,7 @@ public class BrokerStatusSubCommand implements SubCommand { @Override public String commandDesc() { - return "Fetch broker runtime status data"; + return "Fetch broker runtime status data."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/CommitLogSetReadAheadSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/CommitLogSetReadAheadSubCommand.java index b00c7f5f58..4fdabfdf85 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/CommitLogSetReadAheadSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/CommitLogSetReadAheadSubCommand.java @@ -44,7 +44,7 @@ public class CommitLogSetReadAheadSubCommand implements SubCommand { @Override public String commandDesc() { - return "set read ahead mode for all commitlog files"; + return "Set read ahead mode for all commitlog files."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/DeleteExpiredCommitLogSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/DeleteExpiredCommitLogSubCommand.java index a4b2a51adb..142bb7b3c6 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/DeleteExpiredCommitLogSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/DeleteExpiredCommitLogSubCommand.java @@ -37,7 +37,7 @@ public class DeleteExpiredCommitLogSubCommand implements SubCommand { @Override public String commandDesc() { - return "Delete expired CommitLog files"; + return "Delete expired CommitLog files."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java index 5d86c10e45..c4762a2960 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java @@ -45,7 +45,7 @@ public class GetBrokerConfigCommand implements SubCommand { @Override public String commandDesc() { - return "Get broker config by cluster or special broker"; + return "Get broker config by cluster or special broker."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerEpochSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerEpochSubCommand.java index abe8fc6221..1a8961e046 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerEpochSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerEpochSubCommand.java @@ -38,7 +38,7 @@ public class GetBrokerEpochSubCommand implements SubCommand { @Override public String commandDesc() { - return "Fetch broker epoch entries"; + return "Fetch broker epoch entries."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetColdDataFlowCtrInfoSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetColdDataFlowCtrInfoSubCommand.java index 7c54e650c3..34b3ba7d30 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetColdDataFlowCtrInfoSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetColdDataFlowCtrInfoSubCommand.java @@ -47,7 +47,7 @@ public class GetColdDataFlowCtrInfoSubCommand implements SubCommand { @Override public String commandDesc() { - return "get cold data flow ctr info"; + return "Get cold data flow ctr info."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/RemoveColdDataFlowCtrGroupConfigSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/RemoveColdDataFlowCtrGroupConfigSubCommand.java index b0477924f2..f204074803 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/RemoveColdDataFlowCtrGroupConfigSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/RemoveColdDataFlowCtrGroupConfigSubCommand.java @@ -36,7 +36,7 @@ public class RemoveColdDataFlowCtrGroupConfigSubCommand implements SubCommand { @Override public String commandDesc() { - return "remove consumer from cold ctr config"; + return "Remove consumer from cold ctr config."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/ResetMasterFlushOffsetSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/ResetMasterFlushOffsetSubCommand.java index b2ac48c84c..90451b51f5 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/ResetMasterFlushOffsetSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/ResetMasterFlushOffsetSubCommand.java @@ -33,7 +33,7 @@ public class ResetMasterFlushOffsetSubCommand implements SubCommand { @Override public String commandDesc() { - return "Reset master flush offset in slave"; + return "Reset master flush offset in slave."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateBrokerConfigSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateBrokerConfigSubCommand.java index 98abeb6aed..62816ef03a 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateBrokerConfigSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateBrokerConfigSubCommand.java @@ -37,7 +37,7 @@ public class UpdateBrokerConfigSubCommand implements SubCommand { @Override public String commandDesc() { - return "Update broker's config"; + return "Update broker's config."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateColdDataFlowCtrGroupConfigSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateColdDataFlowCtrGroupConfigSubCommand.java index d06a24b579..8d1a000777 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateColdDataFlowCtrGroupConfigSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateColdDataFlowCtrGroupConfigSubCommand.java @@ -39,7 +39,7 @@ public class UpdateColdDataFlowCtrGroupConfigSubCommand implements SubCommand { @Override public String commandDesc() { - return "addOrUpdate cold data flow ctr group config"; + return "Add or update cold data flow ctr group config."; } @Override 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 index 7253970bd2..d755e9e5d8 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 @@ -48,7 +48,7 @@ public class CLusterSendMsgRTCommand implements SubCommand { @Override public String commandDesc() { - return "List All clusters Message Send RT"; + return "List All clusters Message Send RT."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java index a7a840a443..ede0fa5cf4 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java @@ -41,7 +41,7 @@ public class ClusterListSubCommand implements SubCommand { @Override public String commandDesc() { - return "List cluster infos"; + return "List cluster infos."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/connection/ConsumerConnectionSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/connection/ConsumerConnectionSubCommand.java index 630961e31b..35f73d8a03 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/connection/ConsumerConnectionSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/connection/ConsumerConnectionSubCommand.java @@ -39,7 +39,7 @@ public class ConsumerConnectionSubCommand implements SubCommand { @Override public String commandDesc() { - return "Query consumer's socket connection, client version and subscription"; + return "Query consumer's socket connection, client version and subscription."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/connection/ProducerConnectionSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/connection/ProducerConnectionSubCommand.java index 2533982c8f..bde674ab29 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/connection/ProducerConnectionSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/connection/ProducerConnectionSubCommand.java @@ -36,7 +36,7 @@ public class ProducerConnectionSubCommand implements SubCommand { @Override public String commandDesc() { - return "Query producer's socket connection and client version"; + return "Query producer's socket connection and client version."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java index 72b9c975e2..d8f6f9aa92 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java @@ -47,7 +47,7 @@ public class ConsumerStatusSubCommand implements SubCommand { @Override public String commandDesc() { - return "Query consumer's internal data structure"; + return "Query consumer's internal data structure."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/GetConsumerConfigSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/GetConsumerConfigSubCommand.java index 6095e76685..4a8253a025 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/GetConsumerConfigSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/GetConsumerConfigSubCommand.java @@ -43,7 +43,7 @@ public class GetConsumerConfigSubCommand implements SubCommand { @Override public String commandDesc() { - return "Get consumer config by subscription group name"; + return "Get consumer config by subscription group name."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/StartMonitoringSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/StartMonitoringSubCommand.java index 2d08d0bd03..f5e140433e 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/StartMonitoringSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/StartMonitoringSubCommand.java @@ -34,7 +34,7 @@ public class StartMonitoringSubCommand implements SubCommand { @Override public String commandDesc() { - return "Start Monitoring"; + return "Start Monitoring."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/UpdateSubGroupSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/UpdateSubGroupSubCommand.java index f87bafc930..b17da4de45 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/UpdateSubGroupSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/UpdateSubGroupSubCommand.java @@ -41,7 +41,7 @@ public class UpdateSubGroupSubCommand implements SubCommand { @Override public String commandDesc() { - return "Update or create subscription group"; + return "Update or create subscription group."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/container/AddBrokerSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/container/AddBrokerSubCommand.java index e9e5be4a59..007d42ae6d 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/container/AddBrokerSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/container/AddBrokerSubCommand.java @@ -33,7 +33,7 @@ public class AddBrokerSubCommand implements SubCommand { @Override public String commandDesc() { - return "Add a broker to specified container"; + return "Add a broker to specified container."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/container/RemoveBrokerSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/container/RemoveBrokerSubCommand.java index 7c455f8584..ab25d8ebed 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/container/RemoveBrokerSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/container/RemoveBrokerSubCommand.java @@ -33,7 +33,7 @@ public class RemoveBrokerSubCommand implements SubCommand { @Override public String commandDesc() { - return "Remove a broker from specified container"; + return "Remove a broker from specified container."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/controller/CleanControllerBrokerMetaSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/controller/CleanControllerBrokerMetaSubCommand.java index 856e4b4269..24ed025665 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/controller/CleanControllerBrokerMetaSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/controller/CleanControllerBrokerMetaSubCommand.java @@ -37,7 +37,7 @@ public class CleanControllerBrokerMetaSubCommand implements SubCommand { @Override public String commandDesc() { - return "Clean metadata of broker on controller"; + return "Clean metadata of broker on controller."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/controller/GetControllerMetaDataSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/controller/GetControllerMetaDataSubCommand.java index 70bd7f8e98..9664431270 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/controller/GetControllerMetaDataSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/controller/GetControllerMetaDataSubCommand.java @@ -34,7 +34,7 @@ public class GetControllerMetaDataSubCommand implements SubCommand { @Override public String commandDesc() { - return "Get controller cluster's metadata"; + return "Get controller cluster's metadata."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/controller/ReElectMasterSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/controller/ReElectMasterSubCommand.java index 1affe81f9c..a522a903df 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/controller/ReElectMasterSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/controller/ReElectMasterSubCommand.java @@ -37,7 +37,7 @@ public class ReElectMasterSubCommand implements SubCommand { @Override public String commandDesc() { - return "Re-elect the specified broker as master"; + return "Re-elect the specified broker as master."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportConfigsCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportConfigsCommand.java index b8191296d9..03613b29c9 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportConfigsCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportConfigsCommand.java @@ -42,7 +42,7 @@ public class ExportConfigsCommand implements SubCommand { @Override public String commandDesc() { - return "Export configs"; + return "Export configs."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetadataCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetadataCommand.java index 1f9cf7d962..748f7b16e1 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetadataCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetadataCommand.java @@ -46,7 +46,7 @@ public class ExportMetadataCommand implements SubCommand { @Override public String commandDesc() { - return "Export metadata"; + return "Export metadata."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetricsCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetricsCommand.java index a793b4b84b..5d8bb37ba0 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetricsCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetricsCommand.java @@ -56,7 +56,7 @@ public class ExportMetricsCommand implements SubCommand { @Override public String commandDesc() { - return "Export metrics"; + return "Export metrics."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/ha/GetSyncStateSetSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/ha/GetSyncStateSetSubCommand.java index 44b3ec3e18..b6231e4f9b 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/ha/GetSyncStateSetSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/ha/GetSyncStateSetSubCommand.java @@ -40,7 +40,7 @@ public class GetSyncStateSetSubCommand implements SubCommand { @Override public String commandDesc() { - return "Fetch syncStateSet for target brokers"; + return "Fetch syncStateSet for target brokers."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/ha/HAStatusSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/ha/HAStatusSubCommand.java index b1795e046f..931658a08f 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/ha/HAStatusSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/ha/HAStatusSubCommand.java @@ -41,7 +41,7 @@ public class HAStatusSubCommand implements SubCommand { @Override public String commandDesc() { - return "Fetch ha runtime status data"; + return "Fetch ha runtime status data."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/CheckMsgSendRTCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/CheckMsgSendRTCommand.java index 4c6d5ffb60..b15b59d505 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/CheckMsgSendRTCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/CheckMsgSendRTCommand.java @@ -40,7 +40,7 @@ public class CheckMsgSendRTCommand implements SubCommand { @Override public String commandDesc() { - return "Check message send response time"; + return "Check message send response time."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/ConsumeMessageCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/ConsumeMessageCommand.java index 8aed59ea44..02ff53269f 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/ConsumeMessageCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/ConsumeMessageCommand.java @@ -70,7 +70,7 @@ public class ConsumeMessageCommand implements SubCommand { @Override public String commandDesc() { - return "Consume message"; + return "Consume message."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/DumpCompactionLogCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/DumpCompactionLogCommand.java index ae6d9bdcf2..eee8f3d4bd 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/DumpCompactionLogCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/DumpCompactionLogCommand.java @@ -38,7 +38,7 @@ import java.nio.file.Paths; public class DumpCompactionLogCommand implements SubCommand { @Override public String commandDesc() { - return "parse compaction log to message"; + return "Parse compaction log to message."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageByQueueCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageByQueueCommand.java index 654560167f..0418e88a70 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageByQueueCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageByQueueCommand.java @@ -108,7 +108,7 @@ public class PrintMessageByQueueCommand implements SubCommand { @Override public String commandDesc() { - return "Print Message Detail"; + return "Print Message Detail by queueId."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java index d01c36d425..bb82f5079e 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java @@ -62,7 +62,7 @@ public class PrintMessageSubCommand implements SubCommand { @Override public String commandDesc() { - return "Print Message Detail"; + return "Print Message Detail."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java index 2880477f1f..b42612150a 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java @@ -186,7 +186,7 @@ public class QueryMsgByIdSubCommand implements SubCommand { @Override public String commandDesc() { - return "Query Message by Id"; + return "Query Message by Id."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java index ba7b00c3bb..64627fd19f 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java @@ -36,7 +36,7 @@ public class QueryMsgByKeySubCommand implements SubCommand { @Override public String commandDesc() { - return "Query Message by Key"; + return "Query Message by Key."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByOffsetSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByOffsetSubCommand.java index d27313af1e..14d0625fd2 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByOffsetSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByOffsetSubCommand.java @@ -39,7 +39,7 @@ public class QueryMsgByOffsetSubCommand implements SubCommand { @Override public String commandDesc() { - return "Query Message by offset"; + return "Query Message by offset."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByUniqueKeySubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByUniqueKeySubCommand.java index 1b28f8be10..b71cee9016 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByUniqueKeySubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByUniqueKeySubCommand.java @@ -141,7 +141,7 @@ public class QueryMsgByUniqueKeySubCommand implements SubCommand { @Override public String commandDesc() { - return "Query Message by Unique key"; + return "Query Message by Unique key."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgTraceByIdSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgTraceByIdSubCommand.java index 2b982efefd..2c546ec563 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgTraceByIdSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgTraceByIdSubCommand.java @@ -65,7 +65,7 @@ public class QueryMsgTraceByIdSubCommand implements SubCommand { @Override public String commandDesc() { - return "Query a message trace"; + return "Query a message trace."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/SendMessageCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/SendMessageCommand.java index 836ee192b2..970da6b169 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/SendMessageCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/SendMessageCommand.java @@ -41,7 +41,7 @@ public class SendMessageCommand implements SubCommand { @Override public String commandDesc() { - return "Send a message"; + return "Send a message."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/AddWritePermSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/AddWritePermSubCommand.java index 98542d065d..0b0a075bd1 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/AddWritePermSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/AddWritePermSubCommand.java @@ -34,7 +34,7 @@ public class AddWritePermSubCommand implements SubCommand { @Override public String commandDesc() { - return "Add write perm of broker in all name server you defined in the -n param"; + return "Add write perm of broker in all name server you defined in the -n param."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/WipeWritePermSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/WipeWritePermSubCommand.java index 213931ed86..637dd52c86 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/WipeWritePermSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/WipeWritePermSubCommand.java @@ -34,7 +34,7 @@ public class WipeWritePermSubCommand implements SubCommand { @Override public String commandDesc() { - return "Wipe write perm of broker in all name server you defined in the -n param"; + return "Wipe write perm of broker in all name server you defined in the -n param."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/offset/SkipAccumulationSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/offset/SkipAccumulationSubCommand.java index 139821f9c0..b22491a591 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/offset/SkipAccumulationSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/offset/SkipAccumulationSubCommand.java @@ -41,7 +41,7 @@ public class SkipAccumulationSubCommand implements SubCommand { @Override public String commandDesc() { - return "Skip all messages that are accumulated (not consumed) currently"; + return "Skip all messages that are accumulated (not consumed) currently."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/stats/StatsAllSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/stats/StatsAllSubCommand.java index 1d49bbe116..96097a93ed 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/stats/StatsAllSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/stats/StatsAllSubCommand.java @@ -144,7 +144,7 @@ public class StatsAllSubCommand implements SubCommand { @Override public String commandDesc() { - return "Topic and Consumer tps stats"; + return "Topic and Consumer tps stats."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/AllocateMQSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/AllocateMQSubCommand.java index 3fa42f297a..6a9b81eb8a 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/AllocateMQSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/AllocateMQSubCommand.java @@ -41,7 +41,7 @@ public class AllocateMQSubCommand implements SubCommand { @Override public String commandDesc() { - return "Allocate MQ"; + return "Allocate MQ."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicClusterSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicClusterSubCommand.java index 1dab693d95..098f34ff0b 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicClusterSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicClusterSubCommand.java @@ -34,7 +34,7 @@ public class TopicClusterSubCommand implements SubCommand { @Override public String commandDesc() { - return "Get cluster info for topic"; + return "Get cluster info for topic."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicListSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicListSubCommand.java index 346bac704b..d9a279f80e 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicListSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicListSubCommand.java @@ -45,7 +45,7 @@ public class TopicListSubCommand implements SubCommand { @Override public String commandDesc() { - return "Fetch all topic list from name server"; + return "Fetch all topic list from name server."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java index f2dabec4ea..70949d388c 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java @@ -42,7 +42,7 @@ public class TopicRouteSubCommand implements SubCommand { @Override public String commandDesc() { - return "Examine topic route info"; + return "Examine topic route info."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java index fdb249fab6..a1619ecedf 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java @@ -40,7 +40,7 @@ public class TopicStatusSubCommand implements SubCommand { @Override public String commandDesc() { - return "Examine topic Status info"; + return "Examine topic Status info."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateOrderConfCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateOrderConfCommand.java index bebc646b43..3040d04c26 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateOrderConfCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateOrderConfCommand.java @@ -36,7 +36,7 @@ public class UpdateOrderConfCommand implements SubCommand { @Override public String commandDesc() { - return "Create or update or delete order conf"; + return "Create or update or delete order conf."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateStaticTopicSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateStaticTopicSubCommand.java index 85a18c654b..3daeee86ca 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateStaticTopicSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateStaticTopicSubCommand.java @@ -48,7 +48,7 @@ public class UpdateStaticTopicSubCommand implements SubCommand { @Override public String commandDesc() { - return "Update or create static topic, which has fixed number of queues"; + return "Update or create static topic, which has fixed number of queues."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicPermSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicPermSubCommand.java index aaa8815380..d27cd18613 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicPermSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicPermSubCommand.java @@ -44,7 +44,7 @@ public class UpdateTopicPermSubCommand implements SubCommand { @Override public String commandDesc() { - return "Update topic perm"; + return "Update topic perm."; } @Override diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java index b68463396b..2989141756 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java @@ -42,7 +42,7 @@ public class UpdateTopicSubCommand implements SubCommand { @Override public String commandDesc() { - return "Update or create topic"; + return "Update or create topic."; } @Override