提交 323eb5ce 编写于 作者: E evthoriz 提交者: yukon

[ROCKETMQ-234][HOTFIX] Fix Bug, broker will write response twice in batch scenario

Author: evthoriz <evthoriz@gmail.com>

Closes #128 from evthoriz/bugfix.
上级 a9b66d5e
......@@ -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() {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册