fix local mode by making ext-headers remoting protocol compliant

Signed-off-by: Li Zhanhui <[email protected]>
apache · Nov 10, 2023 · 2e5f48f · 2e5f48f
1 parent 27759f3
commit 2e5f48f
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -32,6 +32,7 @@ public static LocalRemotingCommand createRequestCommand(int code, CommandCustomH
         cmd.writeCustomHeader(customHeader);
         cmd.setExtFields(new HashMap<>());
         setCmdVersion(cmd);
+        cmd.makeCustomHeaderToNet();
         return cmd;
     }