commit 90044056cee6eb009b70fb524077728d745057c7
author Zhouxiang Zhan <zhouxzhan@apache.org> Fri Jan 19 17:53:18 2024 +0800
committer GitHub <noreply@github.com> Fri Jan 19 17:53:18 2024 +0800
tree cba7143813c1eee158eae12202e73b69c11e2bed
parent 0aaf9f9763d4353f09f1b04f297bf7e0bc24ad90

[ISSUE #660] Add namespace in metadata (#671)

java/client/src/main/java/org/apache/rocketmq/client/java/rpc/Signature.java

diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/rpc/Signature.java b/java/client/src/main/java/org/apache/rocketmq/client/java/rpc/Signature.java
index c1db9e3..781f197 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/rpc/Signature.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/rpc/Signature.java
@@ -43,6 +43,7 @@
     public static final String LANGUAGE_KEY = "x-mq-language";
     public static final String CLIENT_VERSION_KEY = "x-mq-client-version";
     public static final String PROTOCOL_VERSION = "x-mq-protocol";
+    public static final String NAMESPACE_KEY = "x-mq-namespace";
 
     public static final String ALGORITHM = "MQv2-HMAC-SHA1";
     public static final String CREDENTIAL = "Credential";
@@ -69,6 +70,7 @@
         metadata.put(Metadata.Key.of(REQUEST_ID_KEY, Metadata.ASCII_STRING_MARSHALLER), requestId);
 
         metadata.put(Metadata.Key.of(CLIENT_ID_KEY, Metadata.ASCII_STRING_MARSHALLER), clientId.toString());
+        metadata.put(Metadata.Key.of(NAMESPACE_KEY, Metadata.ASCII_STRING_MARSHALLER), config.getNamespace());
 
         final Optional<SessionCredentialsProvider> optionalSessionCredentialsProvider =
             config.getCredentialsProvider();