[ROCKETMQ-234][HOTFIX] Fix Bug, broker will write response twice in batch scenario
Author: evthoriz <evtho...@gmail.com> Closes #128 from evthoriz/bugfix. Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/323eb5ce Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/323eb5ce Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/323eb5ce Branch: refs/heads/master Commit: 323eb5cebaf4c50d478afbb4d33d844741e7f403 Parents: a9b66d5 Author: evthoriz <evtho...@gmail.com> Authored: Thu Jun 29 16:33:33 2017 +0800 Committer: yukon <yu...@apache.org> Committed: Thu Jun 29 16:33:33 2017 +0800 ---------------------------------------------------------------------- .../apache/rocketmq/broker/processor/SendMessageProcessor.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/323eb5ce/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java ---------------------------------------------------------------------- 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 56a0b99..5c716cc 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() {
