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);