You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2017/06/29 08:35:21 UTC
incubator-rocketmq git commit: [ROCKETMQ-234][HOTFIX] Fix Bug,
broker will write response twice in batch scenario
Repository: incubator-rocketmq
Updated Branches:
refs/heads/develop a9b66d5e5 -> 323eb5ceb
[ROCKETMQ-234][HOTFIX] Fix Bug, broker will write response twice in batch scenario
Author: evthoriz <ev...@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/develop
Commit: 323eb5cebaf4c50d478afbb4d33d844741e7f403
Parents: a9b66d5
Author: evthoriz <ev...@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() {