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

…4466)
apache · Jun 16, 2022 · cd24a24 · cd24a24
1 parent 33fd330
commit cd24a24
Showing 1 changed file with 0 additions and 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
@@ -558,7 +558,6 @@ private RemotingCommand sendBatchMessage(final ChannelHandlerContext ctx,
  } 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;