Revert "[ISSUE apache#3271]Fix handle http message throw IllegalRefer…

…enceCountException" This reverts commit 3a36275.
mytang0 · Feb 27, 2023 · ba4d8da · ba4d8da
1 parent ba4ebe6
commit ba4d8da
Showing 1 changed file with 4 additions and 1 deletion.
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
@@ -95,6 +95,7 @@
 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;
 
@@ -443,7 +444,9 @@ protected void channelRead0(ChannelHandlerContext ctx, HttpRequest httpRequest)
                 }
 
             } catch (Exception ex) {
-                log.error("execute AbstractHTTPServer.HTTPHandler.channelRead0 error", ex);
+                log.error("AbrstractHTTPServer.HTTPHandler.channelRead error", ex);
+            } finally {
+                ReferenceCountUtil.release(httpRequest);
             }
         }