From 16873baf666be81fc63c6a3d91b165de3706d33e Mon Sep 17 00:00:00 2001 From: Romain Brancourt Date: Tue, 10 Jan 2023 14:27:22 +0100 Subject: [PATCH 1/2] [fix] missing schema related function definitions --- lib/c/c_Message.cc | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/lib/c/c_Message.cc b/lib/c/c_Message.cc index 552fa081..2970167c 100644 --- a/lib/c/c_Message.cc +++ b/lib/c/c_Message.cc @@ -127,3 +127,9 @@ const char *pulsar_message_get_topic_name(pulsar_message_t *message) { int pulsar_message_get_redelivery_count(pulsar_message_t *message) { return message->message.getRedeliveryCount(); } + +const char *pulsar_message_get_schemaVersion(pulsar_message_t *message) { + return message->message.getSchemaVersion().c_str(); +} + +int pulsar_message_has_schema_version(pulsar_message_t *message) { return message->message.hasSchemaVersion(); } From 526d2b48c95f14580902d59a523070cd817ff08a Mon Sep 17 00:00:00 2001 From: Romain Brancourt Date: Wed, 11 Jan 2023 10:51:35 +0100 Subject: [PATCH 2/2] [fix] format c_Message.cc --- lib/c/c_Message.cc | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/lib/c/c_Message.cc b/lib/c/c_Message.cc index 2970167c..826ebc17 100644 --- a/lib/c/c_Message.cc +++ b/lib/c/c_Message.cc @@ -132,4 +132,6 @@ const char *pulsar_message_get_schemaVersion(pulsar_message_t *message) { return message->message.getSchemaVersion().c_str(); } -int pulsar_message_has_schema_version(pulsar_message_t *message) { return message->message.hasSchemaVersion(); } +int pulsar_message_has_schema_version(pulsar_message_t *message) { + return message->message.hasSchemaVersion(); +}