You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2023/02/01 15:01:31 UTC
[pulsar-client-reactive] branch main updated: Add getValue to MessageSpec (#120)
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 <cb...@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;
+ }
+
}