(rocketmq-clients) branch master updated: [ISSUE #660] Add namespace in metadata (#671)

[zhouxzhan]

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

zhouxzhan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new 90044056 [ISSUE #660] Add namespace in metadata (#671)
90044056 is described below

commit 90044056cee6eb009b70fb524077728d745057c7
Author: Zhouxiang Zhan <zhouxz...@apache.org>
AuthorDate: Fri Jan 19 17:53:18 2024 +0800

    [ISSUE #660] Add namespace in metadata (#671)
---
 .../src/main/java/org/apache/rocketmq/client/java/rpc/Signature.java    | 2 ++
 1 file changed, 2 insertions(+)

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 c1db9e36..781f1977 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 class Signature {
     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 @@ public class Signature {
         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();