From f334ca18df26c91c430f8645a3cea5610cd17971 Mon Sep 17 00:00:00 2001
From: zhouxiang <zhouxiang.zzx@alibaba-inc.com>
Date: Fri, 20 May 2022 14:45:23 +0800
Subject: [PATCH] [ISSUE #3949] Fix batch sendMessageAsync

---
 .../rocketmq/proxy/service/mqclient/MQClientAPIExt.java       | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIExt.java b/proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIExt.java
index 8826c188a1..c45db7fa37 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIExt.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIExt.java
@@ -190,8 +190,10 @@ public class MQClientAPIExt extends MQClientAPIImpl {
             requestHeader.setBatch(true);
             MessageBatch msgBatch = MessageBatch.generateFromList(msgList);
             MessageClientIDSetter.setUniqID(msgBatch);
-            msgBatch.setBody(msgBatch.encode());
+            byte[] body = msgBatch.encode();
+            msgBatch.setBody(body);
 
+            request.setBody(body);
             this.getRemotingClient().invokeAsync(brokerAddr, request, timeoutMillis, responseFuture -> {
                 RemotingCommand response = responseFuture.getResponseCommand();
                 if (response != null) {