Merge pull request apache#440 from Hellojungle/fix#439

duhengforever · web-flow · commit f6746a76b416 · 2018-09-06T11:33:38.000+08:00
[ISSUE apache#439] fix ConsumeMessageCommand -g option
diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/ConsumeMessageCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/ConsumeMessageCommand.java
@@ -131,7 +131,7 @@ public void execute(final CommandLine commandLine, final Options options, RPCHoo
         try {
             /* Group name must be set before consumer start */
             if (commandLine.hasOption('g')) {
-                String consumerGroup = commandLine.getOptionValue('b').trim();
+                String consumerGroup = commandLine.getOptionValue('g').trim();
                 defaultMQPullConsumer.setConsumerGroup(consumerGroup);
             }
 

Original file line number	Diff line number	Diff line change
`@@ -131,7 +131,7 @@ public void execute(final CommandLine commandLine, final Options options, RPCHoo`
`131`	`131`	`try {`
`132`	`132`	`/* Group name must be set before consumer start */`
`133`	`133`	`if (commandLine.hasOption('g')) {`
`134`		`- String consumerGroup = commandLine.getOptionValue('b').trim();`
	`134`	`+ String consumerGroup = commandLine.getOptionValue('g').trim();`
`135`	`135`	`defaultMQPullConsumer.setConsumerGroup(consumerGroup);`
`136`	`136`	`}`
`137`	`137`