smallrye#2698 Fix: Pulsar - Out of direct memory leak in PulsarNack w…

…hile pool message enabled
kamilchociej · Jul 18, 2024 · 72c9eb3 · 72c9eb3
1 parent 18ede8f
commit 72c9eb3
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...essaging-pulsar/src/main/java/io/smallrye/reactive/messaging/pulsar/fault/PulsarNack.java b/...essaging-pulsar/src/main/java/io/smallrye/reactive/messaging/pulsar/fault/PulsarNack.java
@@ -45,6 +45,7 @@ public Uni<Void> handle(PulsarIncomingMessage<?> message, Throwable reason, Meta
         consumer.negativeAcknowledge(message.getMessageId());
         log.messageFailureNacked(channel, reason.getMessage());
         log.messageFailureFullCause(reason);
+        message.unwrap().release();
         return Uni.createFrom().voidItem()
                 .emitOn(message::runOnMessageContext);
     }