Package org.jboss.netty.channel.group

Examples of org.jboss.netty.channel.group.DefaultChannelGroup

164
165
166
167
168
169
170
171
172
173
174
      this.username = mainApp.getPrefValue("ServerSettingsUsername");
      this.password = mainApp.getPrefValue("ServerSettingsPassword");
    }

    this.ncMgr = new NettyChannelManager(mainApp.getPrefContainer());
    this.channelGroup = new DefaultChannelGroup("HelloNzb-Channels");
    this.newTasks = new Vector<>();

    // Netty factories
    long speedLimit = getSpeedLimit();
    if(speedLimit < 0) speedLimit = 0;
View Full Code Here
461
462
463
464
465
466
467
468
469
470
471
472
473
      }
      bootstrap.setOption("reuseAddress", true);
      bootstrap.setOption("child.reuseAddress", true);
      bootstrap.setOption("child.keepAlive", true);

      channelGroup = new DefaultChannelGroup("hornetq-accepted-channels");

      serverChannelGroup = new DefaultChannelGroup("hornetq-acceptor-channels");

      startServerChannels();

      paused = false;
View Full Code Here
40
41
42
43
44
45
46
    @Provides
    @Singleton
    public ChannelGroup getChannelGroup()
    {
        return new DefaultChannelGroup();
    }
View Full Code Here
55
56
57
58
59
60
61
    public NettyConsumer(NettyEndpoint nettyEndpoint, Processor processor, NettyConfiguration configuration) {
        super(nettyEndpoint, processor);
        this.context = this.getEndpoint().getCamelContext();
        this.configuration = configuration;
        this.allChannels = new DefaultChannelGroup("NettyConsumer-" + nettyEndpoint.getEndpointUri());
    }
View Full Code Here
48
49
50
51
52
53
54
    public NettyConsumer(NettyEndpoint nettyEndpoint, Processor processor, NettyConfiguration configuration) {
        super(nettyEndpoint, processor);
        this.context = this.getEndpoint().getCamelContext();
        this.configuration = configuration;
        this.allChannels = new DefaultChannelGroup("NettyProducer-" + nettyEndpoint.getEndpointUri());
    }
View Full Code Here
411
412
413
414
415
416
417
418
419
420
421
         bootstrap.setOption("sendBufferSize", tcpSendBufferSize);
      }
      bootstrap.setOption("keepAlive", true);
      bootstrap.setOption("reuseAddress", true);

      channelGroup = new DefaultChannelGroup("hornetq-connector");

      final SSLContext context;
      if (sslEnabled)
      {
         try
View Full Code Here
52
53
54
55
56
57
58
    public NettyConsumer(NettyEndpoint nettyEndpoint, Processor processor, NettyConfiguration configuration) {
        super(nettyEndpoint, processor);
        this.context = this.getEndpoint().getCamelContext();
        this.configuration = configuration;
        this.allChannels = new DefaultChannelGroup("NettyConsumer-" + nettyEndpoint.getEndpointUri());
    }
View Full Code Here
131
132
133
134
135
136
137
        private final EnumMap<Event.Type, ChannelGroup> groups = new EnumMap<Event.Type, ChannelGroup>(Event.Type.class);

        public ConnectionTracker()
        {
            for (Event.Type type : Event.Type.values())
                groups.put(type, new DefaultChannelGroup(type.toString()));
        }
View Full Code Here
110
111
112
113
114
115
116
117
118
119
120
                     new ProxyCloseSubscriptionHandler(client.getSubscriber(), tracker));
    }

    protected void initializeNetty() {
        InternalLoggerFactory.setDefaultFactory(new Log4JLoggerFactory());
        allChannels = new DefaultChannelGroup("hedwigproxy");
        ServerBootstrap bootstrap = new ServerBootstrap(serverSocketChannelFactory);
        ChannelDisconnectListener disconnectListener =
            (ChannelDisconnectListener) handlers.get(OperationType.SUBSCRIBE);
        UmbrellaHandler umbrellaHandler =
            new UmbrellaHandler(allChannels, handlers, disconnectListener, false);
View Full Code Here
416
417
418
419
420
421
422
423
424
425
426
                    sm = instantiateSubscriptionManager(tm, pm, dm);
                    rm = instantiateRegionManager(pm, scheduler);
                    sm.addListener(rm);

                    allChannels = new DefaultChannelGroup("hedwig");
                    // Initialize the Netty Handlers (used by the
                    // UmbrellaHandler) once so they can be shared by
                    // both the SSL and non-SSL channels.
                    SubscriptionChannelManager subChannelMgr = new SubscriptionChannelManager();
                    subChannelMgr.addSubChannelDisconnectedListener((SubChannelDisconnectedListener) dm);
View Full Code Here
TOP

Related Classes of org.jboss.netty.channel.group.DefaultChannelGroup

  • co.cask.cdap.internal.app.runtime.procedure.ProcedureProgramRunner
  • co.cask.http.NettyHttpService
  • co.tomlee.guava.services.nifty.NiftyServerService
  • co.tomlee.guava.services.nifty.NiftyService
  • co.tomlee.guava.services.nifty.NiftyThriftServerService
  • com.addthis.meshy.Meshy
  • com.anthavio.httl.NettySender
  • com.biasedbit.nettytutorials.customcodecs.client.Client
  • com.biasedbit.nettytutorials.customcodecs.client.ClientJavaSerialization
  • com.biasedbit.nettytutorials.customcodecs.server.Server
    • 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.