@Override
public void userEventTriggered(final ChannelHandlerContext ctx, Object evt) {
    if (evt.equals(ClientHandshakeStateEvent.HANDSHAKE_COMPLETE)) {
        try {
            connectLocalServer(ctx);
        } catch (Throwable e) {
            logger.error("ForwardClientSocketClientHandler connect local arthas server error", e);
        }
    } else {
        ctx.fireUserEventTriggered(evt);
    }
}
 

@Override
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
    super.userEventTriggered(ctx, evt);
    if (evt instanceof ClientHandshakeStateEvent) {
        if (evt.equals(ClientHandshakeStateEvent.HANDSHAKE_COMPLETE)) {
            handshakeFuture.setSuccess();
        }
    }
}