io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandler.ClientHandshakeStateEvent 源码实例Demo

类 io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandler.ClientHandshakeStateEvent 源码实例Demo

下面列出了 io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandler.ClientHandshakeStateEvent 类实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。


@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);
    }
}
 
源代码2 项目: arthas   文件: LocalFrameHandler.java

@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();
        }
    }
}
 
源代码评论
动弹
沙发等你来抢
 类方法
 同包方法