Added getAck and getNack methods in SolaceIncomingChannel

SolaceLabs · Jan 29, 2024 · 537cd3b · 537cd3b
1 parent fc36d56
commit 537cd3b
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 1 deletion.
diff --git a/...s-connector/src/main/java/com/solace/quarkus/messaging/incoming/SolaceInboundMessage.java b/...s-connector/src/main/java/com/solace/quarkus/messaging/incoming/SolaceInboundMessage.java
@@ -4,6 +4,8 @@
 
 import java.util.concurrent.CompletionStage;
 import java.util.function.Consumer;
+import java.util.function.Function;
+import java.util.function.Supplier;
 
 import org.eclipse.microprofile.reactive.messaging.Metadata;
 
@@ -82,6 +84,16 @@ public Metadata getMetadata() {
         return metadata;
     }
 
+    @Override
+    public Supplier<CompletionStage<Void>> getAck() {
+        return this::ack;
+    }
+
+    @Override
+    public Function<Throwable, CompletionStage<Void>> getNack() {
+        return this::nack;
+    }
+
     @Override
     public CompletionStage<Void> ack() {
         this.unacknowledgedMessageTracker.decrement();

diff --git a/samples/hello-connector-solace/src/main/java/com/solace/quarkus/samples/HelloConsumer.java b/samples/hello-connector-solace/src/main/java/com/solace/quarkus/samples/HelloConsumer.java
@@ -59,7 +59,7 @@ Message<?> consumeAndPublishToDynamicTopic(SolaceInboundMessage<?> p) {
                 .setApplicationMessageId("test")
                 .setDynamicDestination("hello/foobar/" + p.getMessage().getApplicationMessageId())
                 .createPubSubOutboundMetadata();
-        return p.addMetadata(outboundMetadata).withAck(() -> p.ack());
+        return p.addMetadata(outboundMetadata);
     }
 
 }