From 3a362753c43e5fcc36e32e1973e7375a98eb6f2d Mon Sep 17 00:00:00 2001 From: mxsm Date: Sun, 26 Feb 2023 10:22:25 +0800 Subject: [PATCH] [ISSUE #3271]Fix handle http message throw IllegalReferenceCountException --- .../apache/eventmesh/runtime/boot/AbstractHTTPServer.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java index 8a1179ed1f..078eaf9cb9 100644 --- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java +++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java @@ -95,7 +95,6 @@ import io.netty.handler.ssl.SslHandler; import io.netty.handler.timeout.IdleState; import io.netty.handler.timeout.IdleStateEvent; -import io.netty.util.ReferenceCountUtil; import io.opentelemetry.api.trace.Span; import io.opentelemetry.semconv.trace.attributes.SemanticAttributes; @@ -444,9 +443,7 @@ protected void channelRead0(ChannelHandlerContext ctx, HttpRequest httpRequest) } } catch (Exception ex) { - log.error("AbrstractHTTPServer.HTTPHandler.channelRead error", ex); - } finally { - ReferenceCountUtil.release(httpRequest); + log.error("execute AbstractHTTPServer.HTTPHandler.channelRead0 error", ex); } }