diff --git a/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelClientRouteHandler.java b/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelClientRouteHandler.java index e73229ff..9deb35a1 100644 --- a/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelClientRouteHandler.java +++ b/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelClientRouteHandler.java @@ -57,4 +57,8 @@ public class TunnelClientRouteHandler extends BaseRouteHandler { NetContext.getRouter().receive(session, tunnelPacketInfo.packet, tunnelPacketInfo.attachment); } + @Override + public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { + logger.error("{} session exception:[{}]", SessionUtils.sessionSimpleInfo(ctx), cause.getMessage()); + } } diff --git a/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelServerRouteHandler.java b/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelServerRouteHandler.java index fb314b8a..313d981b 100644 --- a/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelServerRouteHandler.java +++ b/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelServerRouteHandler.java @@ -44,4 +44,9 @@ public class TunnelServerRouteHandler extends BaseRouteHandler { TunnelServer.tunnels.remove(ctx.channel()); logger.warn("tunnel server channel is inactive {}", SessionUtils.sessionSimpleInfo(ctx)); } + + @Override + public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { + logger.error("{} session exception:[{}]", SessionUtils.sessionSimpleInfo(ctx), cause.getMessage()); + } }