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/08/01 07:23:47 UTC
[49/50] [abbrv] incubator-rocketmq git commit: [ROCKETMQ-234][HOTFIX]
Fix Bug, broker will write response twice in batch scenario
[ROCKETMQ-234][HOTFIX] Fix Bug, broker will write response twice in batch scenario
Author: evthoriz <ev...@gmail.com>
Closes #128 from evthoriz/bugfix.
(cherry picked from commit 323eb5cebaf4c50d478afbb4d33d844741e7f403)
Signed-off-by: yukon <yu...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/d4149207
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/d4149207
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/d4149207
Branch: refs/heads/develop
Commit: d4149207e27ed3516f1f06407b55986790b806ae
Parents: c297258
Author: evthoriz <ev...@gmail.com>
Authored: Thu Jun 29 16:33:33 2017 +0800
Committer: yukon <yu...@apache.org>
Committed: Thu Jun 29 16:36:08 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/d4149207/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() {