Examples of com.facebook.presto.jdbc.internal.netty.channel.ChannelPipeline.addAfter()

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

Class com.facebook.presto.jdbc.internal.netty.channel.ChannelPipeline

Examples of com.facebook.presto.jdbc.internal.netty.channel.ChannelPipeline.addAfter()

com.facebook.presto.jdbc.internal.netty.channel.ChannelPipeline.addAfter()
Inserts a {@link ChannelHandler} after an existing handler of thispipeline. @param baseName the name of the existing handler @param name the name of the handler to insert after @param handler the handler to insert after @throws NoSuchElementException if there's no such entry with the specified {@code baseName} @throws IllegalArgumentException if there's an entry with the same name already in the pipeline @throws NullPointerException if the specified baseName, name, or handler is {@code null}

        if (ctx == null) {
            throw new IllegalStateException(
                    "Replace cann only be called once the FrameDecoder is added to the ChannelPipeline");
        }
        ChannelPipeline pipeline = ctx.getPipeline();
        pipeline.addAfter(ctx.getName(), handlerName, handler);


        try {
            if (cumulation != null) {
                Channels.fireMessageReceived(ctx, cumulation.readBytes(actualReadableBytes()));
            }

View Full Code Here

        ChannelFuture future = channel.write(request);
        future.addListener(new ChannelFutureListener() {


            public void operationComplete(ChannelFuture future) {
                ChannelPipeline p = future.getChannel().getPipeline();
                p.addAfter(
                        p.getContext(HttpRequestEncoder.class).getName(),
                        "ws-encoder", new WebSocket07FrameEncoder(true));


                if (future.isSuccess()) {
                    handshakeFuture.setSuccess();

View Full Code Here

TOP

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.