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

jinrongtong 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 765a1cbe Change lan to http in nodejs client (#962)
765a1cbe is described below

commit 765a1cbe1a4aa3dcdbb86fc094a4b06e6692c4a0
Author: Drizzle <464473...@qq.com>
AuthorDate: Thu Mar 13 11:38:22 2025 +0800

    Change lan to http in nodejs client (#962)
    
    Co-authored-by: drizzle.zk <drizzle...@alibaba-inc.com>
---
 nodejs/src/client/BaseClient.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/nodejs/src/client/BaseClient.ts b/nodejs/src/client/BaseClient.ts
index 520d62f4..77f790b9 100644
--- a/nodejs/src/client/BaseClient.ts
+++ b/nodejs/src/client/BaseClient.ts
@@ -288,7 +288,7 @@ export abstract class BaseClient {
     // language of client
     // FIXME: java.lang.IllegalArgumentException: No enum constant 
org.apache.rocketmq.remoting.protocol.LanguageCode.nodejs
     // 
https://github.com/apache/rocketmq/blob/master/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/LanguageCode.java
-    metadata.set('x-mq-language', 'NODE_JS');
+    metadata.set('x-mq-language', 'HTTP');
     // version of client
     metadata.set('x-mq-client-version', UserAgent.INSTANCE.version);
     if (this.namespace) {

Reply via email to