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

[ISSUE #3949] Fix batch sendMessageAsync

Browse Source
This commit is contained in:
zhouxiang
2022-07-13 11:29:37 +08:00
parent 0ad9b3adb1
commit f334ca18df
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIExt.java
+3 -1
View File
@@ -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) {