tunnel client close ctx in exceptionCaught. #1720

pull/1523/merge
hengyunabc 4 years ago
parent f9672d6470
commit 985963b9d1

@ -164,9 +164,10 @@ public class TunnelClientSocketClientHandler extends SimpleChannelInboundHandler
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
logger.error("TunnelClient error, tunnel server url: " + tunnelClient.getTunnelServerUrl(), cause);
if (!registerPromise.isDone()) {
registerPromise.setFailure(cause);
}
ctx.fireExceptionCaught(cause);
ctx.close();
}
}

Loading…
Cancel
Save