opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-01 15:47:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #440 from Hellojungle/fix#439

Browse Source 
[ISSUE #439] fix ConsumeMessageCommand -g option
This commit is contained in:
duheng
2018-09-06 11:33:38 +08:00
committed by GitHub
parent 37a642cc12 5898399127
commit f6746a76b4
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tools/src/main/java/org/apache/rocketmq/tools/command/message/ConsumeMessageCommand.java
+1 -1
View File
@@ -131,7 +131,7 @@ public class ConsumeMessageCommand implements SubCommand {
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);
}