Examples of com.facebook.presto.jdbc.internal.netty.channel.SimpleChannelHandler

com.facebook.presto.jdbc.internal.netty.channel.SimpleChannelHandler

all channel state changes. if (e instanceof {@link ChannelStateEvent}) { logger.info("Channel state changed: " + e); } super.handleUpstream(ctx, e); } {@code @Override}public void handleDownstream( {@link ChannelHandlerContext} ctx, {@link ChannelEvent} e) throws Exception {// Log all channel state changes. if (e instanceof {@link MessageEvent}) { logger.info("Writing:: " + e); } super.handleDownstream(ctx, e); } }

    static void setHandshaker(ChannelHandlerContext ctx, WebSocketServerHandshaker handshaker) {
        ctx.setAttachment(handshaker);
    }


    static ChannelHandler forbiddenHttpRequestResponder() {
        return new SimpleChannelHandler() {
            @Override
            public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
                if (!(e.getMessage() instanceof WebSocketFrame)) {
                    DefaultHttpResponse response = new DefaultHttpResponse(HTTP_1_1, HttpResponseStatus.FORBIDDEN);
                    ctx.getChannel().write(response);

Related Classes of com.facebook.presto.jdbc.internal.netty.channel.SimpleChannelHandler

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.