[pulsar-client-reactive] branch main updated: Add getValue to MessageSpec (#120)

[lhotari]

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

lhotari pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git


The following commit(s) were added to refs/heads/main by this push:
     new 8c676db  Add getValue to MessageSpec (#120)
8c676db is described below

commit 8c676db0f70604e1abb0978f966c0916d9ea3aa9
Author: Christophe Bornet <cbor...@hotmail.com>
AuthorDate: Wed Feb 1 16:01:24 2023 +0100

    Add getValue to MessageSpec (#120)
---
 .../java/org/apache/pulsar/reactive/client/api/MessageSpec.java     | 6 ++++++
 .../pulsar/reactive/client/internal/api/DefaultMessageSpec.java     | 5 +++++
 .../pulsar/reactive/client/internal/api/ValueOnlyMessageSpec.java   | 5 +++++
 3 files changed, 16 insertions(+)

diff --git 
a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpec.java
 
b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpec.java
index d8ac241..394aa36 100644
--- 
a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpec.java
+++ 
b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpec.java
@@ -57,4 +57,10 @@ public interface MessageSpec<T> {
                return null;
        }
 
+       /**
+        * Gets the value of this message spec.
+        * @return the value of this message spec
+        */
+       T getValue();
+
 }
diff --git 
a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpec.java
 
b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpec.java
index 8b89945..9635c26 100644
--- 
a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpec.java
+++ 
b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpec.java
@@ -120,6 +120,11 @@ class DefaultMessageSpec<T> implements 
InternalMessageSpec<T> {
                return (C) this.correlationMetadata;
        }
 
+       @Override
+       public T getValue() {
+               return this.value;
+       }
+
        @Override
        public String toString() {
                StringBuilder stringBuilder = new 
StringBuilder().append("DefaultMessageSpec{");
diff --git 
a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/ValueOnlyMessageSpec.java
 
b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/ValueOnlyMessageSpec.java
index c29404b..b116477 100644
--- 
a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/ValueOnlyMessageSpec.java
+++ 
b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/ValueOnlyMessageSpec.java
@@ -44,4 +44,9 @@ class ValueOnlyMessageSpec<T> implements 
InternalMessageSpec<T> {
                return "ValueOnlyMessageSpec{" + "value=" + this.value + '}';
        }
 
+       @Override
+       public T getValue() {
+               return this.value;
+       }
+
 }