diff --git a/src/main/java/net/netty/DisconnectHandler.java b/src/main/java/net/netty/DisconnectHandler.java index 4edd366064..bcb063eed6 100644 --- a/src/main/java/net/netty/DisconnectHandler.java +++ b/src/main/java/net/netty/DisconnectHandler.java @@ -17,7 +17,7 @@ public class DisconnectHandler extends ChannelInboundHandlerAdapter { public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { if (cause instanceof DisconnectException de) { var client = de.getClient(); - transitionService.disconnect(client, true); + transitionService.disconnect(client, de.isShutdown()); } else { ctx.fireExceptionCaught(cause); }