From cd24a244248db32819474328672868a7ff6ee1f2 Mon Sep 17 00:00:00 2001
From: zhichen <zhichen.lc@alibaba-inc.com>
Date: Thu, 16 Jun 2022 08:52:51 +0800
Subject: [PATCH] Fix bug for putting duplicated messsages while sending batch
 message (#4466)

---
 .../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 bfef6cfb8e..437990c932 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;