[ROCKETMQ-234][HOTFIX] Fix Bug, broker will write response twice in b…

…atch scenario Author: evthoriz <evthoriz@gmail.com> Closes #128 from evthoriz/bugfix. (cherry picked from commit 323eb5c) Signed-off-by: yukon <yukon@apache.org>
apache · Jun 29, 2017 · d414920 · d414920
1 parent c297258
commit d414920
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
@@ -532,8 +532,7 @@ private RemotingCommand sendBatchMessage(final ChannelHandlerContext ctx, //
 
         PutMessageResult putMessageResult = this.brokerController.getMessageStore().putMessages(messageExtBatch);
 
-        handlePutMessageResult(putMessageResult, response, request, messageExtBatch, responseHeader, sendMessageContext, ctx, queueIdInt);
-        return response;
+        return handlePutMessageResult(putMessageResult, response, request, messageExtBatch, responseHeader, sendMessageContext, ctx, queueIdInt);
     }
 
     public boolean hasConsumeMessageHook() {