[pulsar-client-reactive] branch main updated: Add methods on MessageResult to ack/nack by Message<> (#21)

[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 c041b47  Add methods on MessageResult to ack/nack by Message<> (#21)
c041b47 is described below

commit c041b47633141bcd5a585eda85825edf6e9e2127
Author: Christophe Bornet <cbor...@hotmail.com>
AuthorDate: Mon Nov 21 17:53:51 2022 +0100

    Add methods on MessageResult to ack/nack by Message<> (#21)
    
    * Add methods on MessageResult to ack/nack by Message<>
    The need for this is frequent when working with the reactive pipeline
    
    * Update 
pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageResult.java
    
    Co-authored-by: Lari Hotari <lhot...@users.noreply.github.com>
    
    * Update 
pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageResult.java
    
    Co-authored-by: Lari Hotari <lhot...@users.noreply.github.com>
    
    Co-authored-by: Lari Hotari <lhot...@users.noreply.github.com>
---
 .../java/org/apache/pulsar/reactive/client/api/MessageResult.java | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageResult.java
 
b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageResult.java
index 6b5fff2..be398bd 100644
--- 
a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageResult.java
+++ 
b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageResult.java
@@ -38,6 +38,14 @@ public interface MessageResult<T> {
                return ApiImplementationFactory.negativeAcknowledge(messageId);
        }
 
+       static <V> MessageResult<Void> acknowledge(Message<V> message) {
+               return acknowledge(message.getMessageId());
+       }
+
+       static <V> MessageResult<Void> negativeAcknowledge(Message<V> message) {
+               return negativeAcknowledge(message.getMessageId());
+       }
+
        static <V> MessageResult<Message<V>> acknowledgeAndReturn(Message<V> 
message) {
                return acknowledge(message.getMessageId(), message);
        }