You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2019/02/21 09:26:50 UTC

[rocketmq] branch develop updated: [ISSUE #776] make mqadmin usage information more friendly to user(#796)

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

dinglei 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 d2fba24  [ISSUE #776] make mqadmin usage information more friendly to user(#796)
d2fba24 is described below

commit d2fba24cab32f5d05a52891fd224d720ad736a86
Author: husterxsp <hu...@qq.com>
AuthorDate: Thu Feb 21 17:26:46 2019 +0800

    [ISSUE #776] make mqadmin usage information more friendly to user(#796)
---
 .../rocketmq/tools/command/topic/UpdateTopicSubCommand.java  | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

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 571f051..c33ae52 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
@@ -19,6 +19,7 @@ package org.apache.rocketmq.tools.command.topic;
 import java.util.Set;
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.Option;
+import org.apache.commons.cli.OptionGroup;
 import org.apache.commons.cli.Options;
 import org.apache.rocketmq.common.TopicConfig;
 import org.apache.rocketmq.common.sysflag.TopicSysFlag;
@@ -43,13 +44,16 @@ public class UpdateTopicSubCommand implements SubCommand {
 
     @Override
     public Options buildCommandlineOptions(Options options) {
+        OptionGroup optionGroup = new OptionGroup();
+
         Option opt = new Option("b", "brokerAddr", true, "create topic to which broker");
-        opt.setRequired(false);
-        options.addOption(opt);
+        optionGroup.addOption(opt);
 
         opt = new Option("c", "clusterName", true, "create topic to which cluster");
-        opt.setRequired(false);
-        options.addOption(opt);
+        optionGroup.addOption(opt);
+
+        optionGroup.setRequired(true);
+        options.addOptionGroup(optionGroup);
 
         opt = new Option("t", "topic", true, "topic name");
         opt.setRequired(true);