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 d3342e818dd969598c9cc84bb3f420189aca61bf..a9e3c64df1e717382e59431e4f0aba1b1cb7d9ab 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 @@ -155,7 +155,7 @@ public class MQAdminStartup { initCommand(new QueryMsgByKeySubCommand()); initCommand(new QueryMsgByUniqueKeySubCommand()); initCommand(new QueryMsgByOffsetSubCommand()); - initCommand(new QueryMsgByUniqueKeySubCommand()); + initCommand(new PrintMessageSubCommand()); initCommand(new PrintMessageByQueueCommand()); initCommand(new SendMsgStatusCommand()); 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 8fdb9d3dbf8f64a63996a2c7537a694a6a4eeb62..27e4c19d7a7448ee4e5701ca8bcc065336db133f 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 @@ -67,15 +67,15 @@ public class UpdateTopicSubCommand implements SubCommand { opt.setRequired(false); options.addOption(opt); - opt = new Option("o", "order", true, "set topic's order(true|false"); + opt = new Option("o", "order", true, "set topic's order(true|false)"); opt.setRequired(false); options.addOption(opt); - opt = new Option("u", "unit", true, "is unit topic (true|false"); + opt = new Option("u", "unit", true, "is unit topic (true|false)"); opt.setRequired(false); options.addOption(opt); - opt = new Option("s", "hasUnitSub", true, "has unit sub (true|false"); + opt = new Option("s", "hasUnitSub", true, "has unit sub (true|false)"); opt.setRequired(false); options.addOption(opt);