This is an automated email from the ASF dual-hosted git repository. zhangyang pushed a commit to branch 5.0.0-alpha in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit d5590167681fb593932ddd02d1dae1ba005c8e48 Author: zhangyang21 <[email protected]> AuthorDate: Thu Nov 18 15:44:07 2021 +0800 [tools] Fix parameter conflicts Signed-off-by: zhangyang21 <[email protected]> --- .../rocketmq/tools/command/consumer/SetConsumeModeSubCommand.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/SetConsumeModeSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/SetConsumeModeSubCommand.java index 9bf5551..9565ace 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/SetConsumeModeSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/SetConsumeModeSubCommand.java @@ -64,7 +64,7 @@ public class SetConsumeModeSubCommand implements SubCommand { opt.setRequired(true); options.addOption(opt); - opt = new Option("n", "popShareQueueNum", true, "num fo queue which share in pop mode"); + opt = new Option("q", "popShareQueueNum", true, "num of queue which share in pop mode"); opt.setRequired(false); options.addOption(opt); @@ -89,8 +89,8 @@ public class SetConsumeModeSubCommand implements SubCommand { int popShareQueueNum = 0; - if (commandLine.hasOption('n')) { - popShareQueueNum = Integer.parseInt(commandLine.getOptionValue('n') + if (commandLine.hasOption('q')) { + popShareQueueNum = Integer.parseInt(commandLine.getOptionValue('q') .trim()); }
