(rocketmq) branch consumer_aware_queue_change updated: fix #7552

[lizhanhui]

This is an automated email from the ASF dual-hosted git repository.

lizhanhui pushed a commit to branch consumer_aware_queue_change
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/consumer_aware_queue_change by 
this push:
     new 4552c339c9 fix #7552
4552c339c9 is described below

commit 4552c339c9584842bafb7343716de3d26efef5bb
Author: Zhanhui Li <lizhan...@apache.org>
AuthorDate: Fri Nov 10 09:53:52 2023 +0000

    fix #7552
    
    Signed-off-by: Zhanhui Li <lizhan...@apache.org>
---
 .../org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java
 
b/proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java
index 915cafcd57..7bf4a16982 100644
--- 
a/proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java
+++ 
b/proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java
@@ -32,6 +32,7 @@ public class LocalRemotingCommand extends RemotingCommand {
         cmd.writeCustomHeader(customHeader);
         cmd.setExtFields(new HashMap<>());
         setCmdVersion(cmd);
+        cmd.makeCustomHeaderToNet();
         return cmd;
     }