opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix bug for putting duplicated messsages while sending batch message (#4466)

Browse Source
This commit is contained in:
zhichen
2022-06-16 08:52:51 +08:00
committed by GitHub
parent 33fd330899
commit cd24a24424
1 changed files with 0 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
-1
View File
@@ -558,7 +558,6 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement
} else {
putMessageResult = this.brokerController.getMessageStore().putMessages(messageExtBatch);
}
putMessageResult = this.brokerController.getMessageStore().putMessage(messageExtBatch);
handlePutMessageResult(putMessageResult, response, request, messageExtBatch, responseHeader, sendMessageContext, ctx, queueIdInt, beginTimeMillis, mappingContext);
sendMessageCallback.onComplete(sendMessageContext, response);
return response;