HubManager.java 文件源码

@Override
        public void initChannel(final SocketChannel ch) throws Exception {
            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("aggregator", new HttpObjectAggregator(1048576));
            p.addLast("qdecoder", queryResultDecoder);
//          p.addLast("logging", loggingHandler);
        }