Examples of io.netty.channel.ChannelPipeline.addBefore()

io.netty.channel.ChannelPipeline.addBefore()
Inserts a {@link ChannelHandler} before an existing handler of thispipeline. @param baseName the name of the existing handler @param name the name of the handler to insert before @param handler the handler to insert before @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}

                        // this means the user use a HttpServerCodec
                        ctx = p.context(HttpServerCodec.class);
                        if (ctx == null) {
                            throw new IllegalStateException("No HttpDecoder and no HttpServerCodec in the pipeline");
                        }
                        p.addBefore(ctx.name(), "wsencoder", newWebsocketDecoder());
                        p.replace(ctx.name(), "wsdecoder", newWebSocketEncoder());
                    } else {
                        p.remove(HttpRequestDecoder.class);
                        p.remove(HttpResponseEncoder.class);
                    }

View Full Code Here

                        if (ctx == null) {
                            promise.setFailure(
                                    new IllegalStateException("No HttpDecoder and no HttpServerCodec in the pipeline"));
                            return;
                        }
                        p.addBefore(ctx.name(), "wsencoder", newWebsocketDecoder());
                        p.replaceAndForward(ctx.name(), "wsdecoder", newWebSocketEncoder());
                    } else {
                        p.replaceAndForward(ctx.name(), "wsdecoder", newWebsocketDecoder());


                        p.replace(HttpResponseEncoder.class, "wsencoder", newWebSocketEncoder());

View Full Code Here

        nettyHeaders = null;
      }
      handshaker = WebSocketClientHandshakerFactory.newHandshaker(wsuri, version, subProtocols, false,
                                                                  nettyHeaders, maxWebSocketFrameSize);
      ChannelPipeline p = channel.pipeline();
      p.addBefore("handler", "handshakeCompleter", new HandshakeInboundHandler(wsConnect, version != WebSocketVersion.V00));
      handshaker.handshake(channel).addListener(future -> {
        if (!future.isSuccess()) {
          client.handleException((Exception) future.cause());
        }
      });

View Full Code Here


    @Override
    protected void addCodec(ChannelHandlerContext ctx) throws Exception {
        ChannelPipeline p = ctx.pipeline();
        String name = ctx.name();
        p.addBefore(name, null, codec);
    }


    @Override
    protected void removeEncoder(ChannelHandlerContext ctx) throws Exception {
        ctx.pipeline().remove(codec.encoder());

View Full Code Here

    protected void addCodec(ChannelHandlerContext ctx) throws Exception {
        ChannelPipeline p = ctx.pipeline();
        String name = ctx.name();


        Socks4CmdResponseDecoder decoder = new Socks4CmdResponseDecoder();
        p.addBefore(name, null, decoder);


        decoderName = p.context(decoder).name();
        encoderName = decoderName + ".encoder";


        p.addBefore(name, encoderName, Socks4MessageEncoder.INSTANCE);

View Full Code Here

        p.addBefore(name, null, decoder);


        decoderName = p.context(decoder).name();
        encoderName = decoderName + ".encoder";


        p.addBefore(name, encoderName, Socks4MessageEncoder.INSTANCE);
    }


    @Override
    protected void removeEncoder(ChannelHandlerContext ctx) throws Exception {
        ChannelPipeline p = ctx.pipeline();

View Full Code Here

    protected void addCodec(ChannelHandlerContext ctx) throws Exception {
        ChannelPipeline p = ctx.pipeline();
        String name = ctx.name();


        Socks5InitResponseDecoder decoder = new Socks5InitResponseDecoder();
        p.addBefore(name, null, decoder);


        decoderName = p.context(decoder).name();
        encoderName = decoderName + ".encoder";


        p.addBefore(name, encoderName, Socks5MessageEncoder.INSTANCE);

View Full Code Here

        p.addBefore(name, null, decoder);


        decoderName = p.context(decoder).name();
        encoderName = decoderName + ".encoder";


        p.addBefore(name, encoderName, Socks5MessageEncoder.INSTANCE);
    }


    @Override
    protected void removeEncoder(ChannelHandlerContext ctx) throws Exception {
        ctx.pipeline().remove(encoderName);

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.