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) {