[ISSUE #483] Expose message store host and born host C interface (#484)
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 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 @@
}
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