Package io.netty.channel

Examples of io.netty.channel.ChannelPipelineFactory

49
50
51
52
53
54
55
56
57
58
59
        final ExecutionHandler executionHandler = new ExecutionHandler(
                new OrderedMemoryAwareThreadPoolExecutor(16, 1048576, 1048576));

        // Set up the pipeline factory.
        bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
            @Override
            public ChannelPipeline getPipeline() throws Exception {
                return Channels.pipeline(executionHandler, new SctpClientHandler());
            }
        });
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
                new NioServerSocketChannelFactory(
                        Executors.newCachedThreadPool(),
                        Executors.newCachedThreadPool()));

        // Set up the pipeline factory.
        bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
            public ChannelPipeline getPipeline() throws Exception {
                return Channels.pipeline(
                        new ObjectEncoder(),
                        new ObjectDecoder(),
                        new ObjectEchoServerHandler());
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
        sb.bind(socketAddress);

        ClientBootstrap cb = new ClientBootstrap(
                new DefaultLocalClientChannelFactory());

        cb.setPipelineFactory(new ChannelPipelineFactory() {
            public ChannelPipeline getPipeline() throws Exception {
                return Channels.pipeline(
                        new StringDecoder(),
                        new StringEncoder(),
                        new LoggingHandler(InternalLogLevel.INFO));
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
                new NioServerSocketChannelFactory(
                        Executors.newCachedThreadPool(),
                        Executors.newCachedThreadPool()));

        // Set up the pipeline factory.
        bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
            public ChannelPipeline getPipeline() throws Exception {
                return Channels.pipeline(new DiscardServerHandler());
            }
        });
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
    public void run() {
        final ExecutorService executorService = Executors.newCachedThreadPool();
        final ClientBootstrap bootstrap = new ClientBootstrap(new IoStreamChannelFactory(executorService));

        // Configure the event pipeline factory.
        bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
            @Override
            public ChannelPipeline getPipeline() throws Exception {
                DefaultChannelPipeline pipeline = new DefaultChannelPipeline();
                pipeline.addLast("framer", new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter()));
                pipeline.addLast("decoder", new StringDecoder());
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
                new NioClientSocketChannelFactory(
                        Executors.newCachedThreadPool(),
                        Executors.newCachedThreadPool()));

        // Set up the pipeline factory.
        bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
            public ChannelPipeline getPipeline() throws Exception {
                return Channels.pipeline(
                        new DiscardClientHandler(firstMessageSize));
            }
        });
View Full Code Here
TOP

Related Classes of io.netty.channel.ChannelPipelineFactory

  • io.netty.example.discard.DiscardClient
  • io.netty.example.discard.DiscardServer
  • io.netty.example.echo.EchoClient
  • io.netty.example.echo.EchoServer
  • io.netty.example.http.websocketx.client.WebSocketClient
  • io.netty.example.local.LocalExample
  • io.netty.example.local.LocalExampleMultithreaded
  • io.netty.example.objectecho.ObjectEchoClient
  • io.netty.example.objectecho.ObjectEchoServer
  • io.netty.example.portunification.PortUnificationServer
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.