(pulsar-client-node) branch master updated: Support get the producer name of a message (#444)

[xyz]

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

xyz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-node.git


The following commit(s) were added to refs/heads/master by this push:
     new fc65c32  Support get the producer name of a message (#444)
fc65c32 is described below

commit fc65c326e370d9c851dbe0f1603c22a3646ec3fb
Author: Baodi Shi <ba...@apache.org>
AuthorDate: Wed Dec 17 09:47:21 2025 +0800

    Support get the producer name of a message (#444)
---
 index.d.ts               |  1 +
 src/Message.cc           | 11 ++++++++++-
 src/Message.h            |  1 +
 tests/end_to_end.test.js |  3 +++
 4 files changed, 15 insertions(+), 1 deletion(-)

diff --git a/index.d.ts b/index.d.ts
index 9dc3e8f..46ac69a 100644
--- a/index.d.ts
+++ b/index.d.ts
@@ -170,6 +170,7 @@ export class Message {
   getRedeliveryCount(): number;
   getPartitionKey(): string;
   getOrderingKey(): string;
+  getProducerName(): string;
 }
 
 export class MessageId {
diff --git a/src/Message.cc b/src/Message.cc
index 184b8e7..8b1d081 100644
--- a/src/Message.cc
+++ b/src/Message.cc
@@ -46,7 +46,8 @@ Napi::Object Message::Init(Napi::Env env, Napi::Object 
exports) {
        InstanceMethod("getEventTimestamp", &Message::GetEventTimestamp),
        InstanceMethod("getRedeliveryCount", &Message::GetRedeliveryCount),
        InstanceMethod("getPartitionKey", &Message::GetPartitionKey),
-       InstanceMethod("getOrderingKey", &Message::GetOrderingKey)});
+       InstanceMethod("getOrderingKey", &Message::GetOrderingKey),
+       InstanceMethod("getProducerName", &Message::GetProducerName)});
 
   constructor = Napi::Persistent(func);
   constructor.SuppressDestruct();
@@ -147,6 +148,14 @@ Napi::Value Message::GetOrderingKey(const 
Napi::CallbackInfo &info) {
   return Napi::String::New(env, 
pulsar_message_get_orderingKey(this->cMessage.get()));
 }
 
+Napi::Value Message::GetProducerName(const Napi::CallbackInfo &info) {
+  Napi::Env env = info.Env();
+  if (!ValidateCMessage(env)) {
+    return env.Null();
+  }
+  return Napi::String::New(env, 
pulsar_message_get_producer_name(this->cMessage.get()));
+}
+
 bool Message::ValidateCMessage(Napi::Env env) {
   if (this->cMessage.get()) {
     return true;
diff --git a/src/Message.h b/src/Message.h
index 6097f1c..417de92 100644
--- a/src/Message.h
+++ b/src/Message.h
@@ -45,6 +45,7 @@ class Message : public Napi::ObjectWrap<Message> {
   Napi::Value GetEventTimestamp(const Napi::CallbackInfo &info);
   Napi::Value GetPartitionKey(const Napi::CallbackInfo &info);
   Napi::Value GetOrderingKey(const Napi::CallbackInfo &info);
+  Napi::Value GetProducerName(const Napi::CallbackInfo &info);
   Napi::Value GetRedeliveryCount(const Napi::CallbackInfo &info);
   bool ValidateCMessage(Napi::Env env);
 
diff --git a/tests/end_to_end.test.js b/tests/end_to_end.test.js
index 2c08418..e652c79 100644
--- a/tests/end_to_end.test.js
+++ b/tests/end_to_end.test.js
@@ -40,11 +40,13 @@ const Pulsar = require('../index');
         } : {}),
       });
 
+      const producerName = 'test-producer';
       const topic = 'persistent://public/default/produce-consume';
       const producer = await client.createProducer({
         topic,
         sendTimeoutMs: 30000,
         batchingEnabled: true,
+        producerName,
       });
       expect(producer).not.toBeNull();
 
@@ -70,6 +72,7 @@ const Pulsar = require('../index');
       for (let i = 0; i < 10; i += 1) {
         const msg = await consumer.receive();
         consumer.acknowledge(msg);
+        expect(msg.getProducerName()).toBe(producerName);
         results.push(msg.getData().toString());
       }
       expect(lodash.difference(messages, results)).toEqual([]);