You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2022/06/16 00:53:08 UTC
[rocketmq] branch 5.0.0-beta updated: Fix bug for putting duplicated messsages while sending batch message (#4466)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch 5.0.0-beta
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/5.0.0-beta by this push:
new cd24a2442 Fix bug for putting duplicated messsages while sending batch message (#4466)
cd24a2442 is described below
commit cd24a244248db32819474328672868a7ff6ee1f2
Author: zhichen <zh...@alibaba-inc.com>
AuthorDate: Thu Jun 16 08:52:51 2022 +0800
Fix bug for putting duplicated messsages while sending batch message (#4466)
---
.../java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java | 1 -
1 file changed, 1 deletion(-)
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 bfef6cfb8..437990c93 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
@@ -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;