HubManager.java 文件源码

/**
     * {@inheritDoc}
     * @see io.netty.channel.pool.ChannelPoolHandler#channelCreated(io.netty.channel.Channel)
     */
    @Override
    public void channelCreated(final Channel ch) throws Exception {
        log.debug("Channel Created: {}", ch);
        channelGroup.add(ch);
        final ChannelPipeline p = ch.pipeline();
        //p.addLast("timeout",    new IdleStateHandler(0, 0, 60));  // TODO: configurable       
        p.addLast("httpcodec",    new HttpClientCodec());
        p.addLast("inflater",   new HttpContentDecompressor());
//      p.addLast("deflater",   new HttpContentCompressor());
        p.addLast("aggregator", new HttpObjectAggregator(20485760));
//      p.addLast("logging", loggingHandler);
        p.addLast("qdecoder", queryResultDecoder);

    }