From 74b8020bb0be13e725b7ea0ab780031597bb7c53 Mon Sep 17 00:00:00 2001 From: Chaiyong Ragkhitwetsagul Date: Sun, 2 Aug 2026 05:18:02 +0700 Subject: [PATCH] Update PortForwarder.java Released reference-counted messages when the test port forwarder's outbound channel is inactive. Signed-off-by: Chaiyong Ragkhitwetsagul --- .../test/java/org/apache/pulsar/broker/auth/PortForwarder.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/PortForwarder.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/PortForwarder.java index 5c9136a6ad8f6..8942ba41aa460 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/PortForwarder.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/PortForwarder.java @@ -34,6 +34,7 @@ import io.netty.channel.socket.nio.NioServerSocketChannel; import io.netty.handler.logging.LogLevel; import io.netty.handler.logging.LoggingHandler; +import io.netty.util.ReferenceCountUtil; import java.net.SocketAddress; import lombok.CustomLog; @@ -141,6 +142,8 @@ public void operationComplete(ChannelFuture future) { } } }); + } else { + ReferenceCountUtil.release(msg); } }