proper way of removing a handler

Signed-off-by: Maxim Nesen <maxim.nesen@oracle.com>
senivam · Oct 18, 2023 · 6bc0812 · 6bc0812
1 parent b074c47
commit 6bc0812
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...ector/src/main/java/org/glassfish/jersey/netty/connector/JerseyExpectContinueHandler.java b/...ector/src/main/java/org/glassfish/jersey/netty/connector/JerseyExpectContinueHandler.java
@@ -56,11 +56,11 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception
             if (!HttpResponseStatus.CONTINUE.equals(response.status())) {
                 ctx.fireChannelRead(msg); //bypass the message to the next handler in line
             } else {
-                ctx.pipeline().remove(this);
+                ctx.pipeline().remove(JerseyExpectContinueHandler.class);
             }
         } else {
             if (!isExpected) {
-                ctx.pipeline().remove(this);
+                ctx.pipeline().remove(JerseyExpectContinueHandler.class);
             }
             ctx.fireChannelRead(msg); //bypass the message to the next handler in line
         }
@@ -94,7 +94,7 @@ CompletableFuture<HttpResponseStatus> processExpect100ContinueRequest(HttpReques
                 : null;
         isExpected = expect100ContinueFuture != null;
         if (!isExpected) {
-            ch.pipeline().remove(this);
+            ch.pipeline().remove(JerseyExpectContinueHandler.class);
         } else {
             final HttpResponseStatus status = expectedFuture
                     .get(timeout, TimeUnit.MILLISECONDS);