[pulsar] branch branch-2.3 updated: Exposing getSchemaVersion in the client by making it public. (#3744)

[mmerli]

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

mmerli pushed a commit to branch branch-2.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.3 by this push:
     new 515a55e  Exposing getSchemaVersion in the client by making it public. 
(#3744)
515a55e is described below

commit 515a55e327dc26a2771d342b29ab8c85cdc50ccf
Author: Yuvaraj L <uvar...@gmail.com>
AuthorDate: Tue Mar 5 00:58:36 2019 +0530

    Exposing getSchemaVersion in the client by making it public. (#3744)
    
    * Exposing getSchemaVersion in the client by making it public.
    
    * Implemented getSchemaVersion in TopicMessageImpl.java
    
    * Changed the release version
---
 .../src/main/java/org/apache/pulsar/client/api/Message.java        | 7 +++++++
 .../src/main/java/org/apache/pulsar/client/impl/MessageImpl.java   | 3 ++-
 .../main/java/org/apache/pulsar/client/impl/TopicMessageImpl.java  | 5 +++++
 3 files changed, 14 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Message.java 
b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Message.java
index 58e6162..e672ab0 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Message.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Message.java
@@ -180,4 +180,11 @@ public interface Message<T> {
      * @return message redelivery count
      */
     int getRedeliveryCount();
+
+    /**
+     * Get schema version of the message.
+     * @since 2.4.0
+     * @return Schema version of the message if the message is produced with 
schema otherwise null.
+     */
+    byte[] getSchemaVersion();
 }
diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java
index 665fd36..30e1474 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java
@@ -228,7 +228,8 @@ public class MessageImpl<T> implements Message<T> {
         }
     }
 
-    private byte[] getSchemaVersion() {
+    @Override
+    public byte[] getSchemaVersion() {
         if (msgMetadataBuilder.hasSchemaVersion()) {
             return msgMetadataBuilder.getSchemaVersion().toByteArray();
         } else {
diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicMessageImpl.java
 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicMessageImpl.java
index bf6b281..fff104d 100644
--- 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicMessageImpl.java
+++ 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicMessageImpl.java
@@ -143,6 +143,11 @@ public class TopicMessageImpl<T> implements Message<T> {
         return msg.getRedeliveryCount();
     }
 
+    @Override
+    public byte[] getSchemaVersion() {
+        return msg.getSchemaVersion();
+    }
+
     public Message<T> getMessage() {
         return msg;
     }