Package org.jboss.netty.channel

Examples of org.jboss.netty.channel.ChannelPipelineFactory

174
175
176
177
178
179
180
181
182
183
184
        nettyClientBootstrapOptions.get(NETTY_CONNECT_TIMEOUT_OPTION);
    bootstrap = new ClientBootstrap(channelFactory);
    remoteAddr = addr;

    // Configure the event pipeline factory.
    bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
      @Override
      public ChannelPipeline getPipeline() throws Exception {
        ChannelPipeline p = Channels.pipeline();
        p.addLast("frameDecoder", new NettyFrameDecoder());
        p.addLast("frameEncoder", new NettyFrameEncoder());
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
  @Override
  public void start() {
    // setup Netty server
    ConnectionlessBootstrap serverBootstrap = new ConnectionlessBootstrap
        (new OioDatagramChannelFactory(Executors.newCachedThreadPool()));
    serverBootstrap.setPipelineFactory(new ChannelPipelineFactory() {
      public ChannelPipeline getPipeline() {
       return Channels.pipeline(new syslogHandler());
      }
     });
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
  public void start() {
    ChannelFactory factory = new NioServerSocketChannelFactory(
        Executors.newCachedThreadPool(), Executors.newCachedThreadPool());

    ServerBootstrap serverBootstrap = new ServerBootstrap(factory);
    serverBootstrap.setPipelineFactory(new ChannelPipelineFactory() {
      public ChannelPipeline getPipeline() {
        return Channels.pipeline(new syslogTcpHandler());
      }
    });
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
    this.workerCount = workercount;
    this.pipelineFactory = getPipelineFactory();
  }

  public ChannelPipelineFactory getPipelineFactory() {
    return new ChannelPipelineFactory() {
      @Override
      public ChannelPipeline getPipeline() {
        return Channels.pipeline(new RpcFrameDecoder(),
            new SimpleTcpServerHandler(rpcProgram));
      }
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
  private void startTCPServer() {
    SimpleTcpServer tcpServer = new SimpleTcpServer(Nfs3Constant.PORT,
        rpcProgram, 0) {
      @Override
      public ChannelPipelineFactory getPipelineFactory() {
        return new ChannelPipelineFactory() {
          @Override
          public ChannelPipeline getPipeline() {
            return Channels.pipeline(new RpcFrameDecoder(),
                new SimpleTcpServerHandler(rpcProgram));
          }
View Full Code Here
141
142
143
144
145
146
147
148
149
150
151
      super(host, port, request, oneShot);
    }

    @Override
    protected ChannelPipelineFactory setPipelineFactory() {
      this.pipelineFactory = new ChannelPipelineFactory() {
        public ChannelPipeline getPipeline() {
          return Channels.pipeline(new RpcFrameDecoder(), new WriteHandler(
              request));
        }
      };
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
  public SimpleUdpServer(int port, RpcProgram program, int workerCount) {
    this.port = port;
    this.rpcProgram = program;
    this.workerCount = workerCount;
    this.pipelineFactory = new ChannelPipelineFactory() {
      @Override
      public ChannelPipeline getPipeline() {
        return Channels.pipeline(new SimpleUdpServerHandler(rpcProgram));
      }
    };
View Full Code Here
50
51
52
53
54
55
56
57
58
59
60
    this.request = request;
    this.oneShot = oneShot;
  }
 
  protected ChannelPipelineFactory setPipelineFactory() {
    this.pipelineFactory = new ChannelPipelineFactory() {
      @Override
      public ChannelPipeline getPipeline() {
        return Channels.pipeline(new RpcFrameDecoder(),
            new SimpleTcpClientHandler(request));
      }
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
        if (started) throw new IllegalStateException("Server running already");

        if (addresses.isEmpty()) throw new RuntimeException("Please specify at least on socketaddress to which the server should get bound!");

        bootstrap = new ServerBootstrap(createSocketChannelFactory());
        ChannelPipelineFactory factory = createPipelineFactory(channels);
       
        // Configure the pipeline factory.
        bootstrap.setPipelineFactory(factory);
        configureBootstrap(bootstrap);
       
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
    this.channelFactory = channelFactory;
    bootstrap = new ClientBootstrap(channelFactory);
    remoteAddr = addr;

    // Configure the event pipeline factory.
    bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
      @Override
      public ChannelPipeline getPipeline() throws Exception {
        ChannelPipeline p = Channels.pipeline();
        p.addLast("frameDecoder", new NettyFrameDecoder());
        p.addLast("frameEncoder", new NettyFrameEncoder());
View Full Code Here
TOP

Related Classes of org.jboss.netty.channel.ChannelPipelineFactory

  • co.cask.cdap.gateway.router.NettyRouter
  • co.cask.tigon.sql.ioserver.InputServerSocket
  • com.addthis.meshy.Meshy
  • com.addthis.meshy.MeshyServer
  • com.alibaba.dubbo.remoting.transport.netty.NettyServer
  • com.alibaba.otter.canal.server.netty.CanalServerWithNetty
  • com.barchart.feed.ddf.datalink.provider.FeedClientDDF
  • com.barchart.feed.ddf.datalink.provider.HistoricReplayListenerClientDDF
  • com.barchart.feed.ddf.datalink.provider.TCPListenerClientDDF
  • com.barchart.feed.ddf.datalink.provider.UDPListenerClientDDF
    • 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.