From 323eb5cebaf4c50d478afbb4d33d844741e7f403 Mon Sep 17 00:00:00 2001 From: evthoriz Date: Thu, 29 Jun 2017 16:33:33 +0800 Subject: [PATCH] [ROCKETMQ-234][HOTFIX] Fix Bug, broker will write response twice in batch scenario Author: evthoriz Closes #128 from evthoriz/bugfix. --- .../apache/rocketmq/broker/processor/SendMessageProcessor.java | 3 +-- 1 file changed, 1 insertion(+), 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 index 56a0b990..5c716cc8 100644 --- 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 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement 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() { -- GitLab