You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2022/02/08 02:43:47 UTC
[rocketmq] 04/17: [tools] Fix parameter conflicts
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch 5.0.0-alpha
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit a01433094b46fb89dc64b18fbd224897cbe11c86
Author: zhangyang21 <zh...@xiaomi.com>
AuthorDate: Thu Nov 18 15:44:07 2021 +0800
[tools] Fix parameter conflicts
Signed-off-by: zhangyang21 <zh...@xiaomi.com>
---
.../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());
}