(rocketmq-client-cpp) branch master updated: [ISSUE #483] Expose message store host and born host C interface (#484)

[lizhimin]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 7c8b7f8  [ISSUE #483] Expose message store host and born host C 
interface (#484)
7c8b7f8 is described below

commit 7c8b7f8bf52ba753bb305faa926fe40a4a9c1969
Author: Humkum <1109939...@qq.com>
AuthorDate: Tue Mar 17 10:07:22 2026 +0800

    [ISSUE #483] Expose message store host and born host C interface (#484)
---
 include/CMessageExt.h      |  2 ++
 src/extern/CMessageExt.cpp | 14 ++++++++++++++
 2 files changed, 16 insertions(+)

diff --git a/include/CMessageExt.h b/include/CMessageExt.h
index ae216e0..818ee72 100644
--- a/include/CMessageExt.h
+++ b/include/CMessageExt.h
@@ -43,6 +43,8 @@ ROCKETMQCLIENT_API long long 
GetMessageStoreTimestamp(CMessageExt* msgExt);
 ROCKETMQCLIENT_API long long GetMessageQueueOffset(CMessageExt* msgExt);
 ROCKETMQCLIENT_API long long GetMessageCommitLogOffset(CMessageExt* msgExt);
 ROCKETMQCLIENT_API long long GetMessagePreparedTransactionOffset(CMessageExt* 
msgExt);
+ROCKETMQCLIENT_API const char* GetMessageStoreHost(CMessageExt* msg);
+ROCKETMQCLIENT_API const char* GetMessageBornHost(CMessageExt* msg);
 
 #ifdef __cplusplus
 }
diff --git a/src/extern/CMessageExt.cpp b/src/extern/CMessageExt.cpp
index 45da289..a85a27d 100644
--- a/src/extern/CMessageExt.cpp
+++ b/src/extern/CMessageExt.cpp
@@ -130,6 +130,20 @@ long long GetMessagePreparedTransactionOffset(CMessageExt* 
msg) {
   }
   return ((MQMessageExt*)msg)->getPreparedTransactionOffset();
 }
+
+const char* GetMessageStoreHost(CMessageExt* msg) {
+  if (msg == NULL) {
+    return NULL;
+  }
+  return ((MQMessageExt*) msg)->getStoreHostString().c_str();
+}
+
+const char* GetMessageBornHost(CMessageExt* msg) {
+  if (msg == NULL) {
+    return NULL;
+  }
+  return ((MQMessageExt*) msg)->getBornHostString().c_str();
+}
 #ifdef __cplusplus
 };
 #endif