fix issue 522

Author: zhanglistar

include/pulsar/Message.h

@@ -197,6 +197,11 @@ class PULSAR_PUBLIC Message {
      */
     const std::string& getSchemaVersion() const;
 
+    /**
+     * Set the schema version of the message.
+     */
+    void setSchemaVersion(const std::string& schemaVersion);
+
     /**
      * Get the producer name which produced this message.
      *

lib/Message.cc

@@ -209,6 +209,12 @@ const std::string& Message::getSchemaVersion() const {
     return impl_->getSchemaVersion();
 }
 
+void Message::setSchemaVersion(const std::string& schemaVersion) {
+    if (impl_) {
+        impl_->metadata.set_schema_version(schemaVersion);
+    }
+}
+
 uint64_t Message::getPublishTimestamp() const { return impl_ ? impl_->getPublishTimestamp() : 0ull; }
 
 uint64_t Message::getEventTimestamp() const { return impl_ ? impl_->getEventTimestamp() : 0ull; }

lib/c/c_Message.cc

@@ -141,6 +141,10 @@ int pulsar_message_has_schema_version(pulsar_message_t *message) {
     return message->message.hasSchemaVersion();
 }
 
+void pulsar_message_set_schema_version(pulsar_message_t *message, const char *schemaVersion) {
+    message->message.setSchemaVersion(schemaVersion ? schemaVersion : "");
+}
+
 const char *pulsar_message_get_producer_name(pulsar_message_t *message) {
     return message->message.getProducerName().c_str();
 }