Merge pull request smallrye#2580 from michalcukierman/patch-2

Corrected message.release() in PulsarMessageAck.java
michalcukierman · Apr 15, 2024 · b38a33b · b38a33b
2 parents 04a35a3 + bea5d16
commit b38a33b
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/...ging-pulsar/src/main/java/io/smallrye/reactive/messaging/pulsar/ack/PulsarMessageAck.java b/...ging-pulsar/src/main/java/io/smallrye/reactive/messaging/pulsar/ack/PulsarMessageAck.java
@@ -41,7 +41,6 @@ public Uni<Void> handle(PulsarIncomingMessage<?> message) {
         return Uni.createFrom().completionStage(() -> {
             var txnMetadata = message.getMetadata(PulsarTransactionMetadata.class);
             if (txnMetadata.isPresent()) {
-                message.unwrap().release();
                 return consumer.acknowledgeAsync(messageId, txnMetadata.get().getTransaction());
             } else {
                 return consumer.acknowledgeAsync(messageId);