PipelineFactory.java 文件源码

/**
 * Modifies the pipeline to handle HTTP requests
 * @param ctx The calling channel handler context
 * @param maxRequestSize The maximum request size in bytes
 */
private void switchToHttp(final ChannelHandlerContext ctx, final int maxRequestSize) {
    ChannelPipeline p = ctx.pipeline();         
    p.addLast("httpHandler", new HttpServerCodec());  // TODO: config ?
    p.addLast("decompressor", new HttpContentDecompressor());
    p.addLast("aggregator", new HttpObjectAggregator(maxRequestSize)); 
    p.addLast("jsonDecoder", new JsonObjectDecoder(maxRequestSize, false));
    p.addLast("handler", jsonRpcHandler);
    p.remove(this);
}