/**
      This file is part of GoldenGate Project (named also GoldenGate or GG).
   
      Copyright 2009, Frederic Bregier, and individual contributors by the @author
      tags. See the COPYRIGHT.txt in the distribution for a full listing of
      individual contributors.
   
      All GoldenGate Project is free software: you can redistribute it and/or 
      modify it under the terms of the GNU General Public License as published 
     by the Free Software Foundation, either version 3 of the License, or
     (at your option) any later version.
  
     GoldenGate is distributed in the hope that it will be useful,
     but WITHOUT ANY WARRANTY; without even the implied warranty of
     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
     GNU General Public License for more details.
  
     You should have received a copy of the GNU General Public License
     along with GoldenGate .  If not, see <http://www.gnu.org/licenses/>.
   */
  package openr66.protocol.http;
  
  import static org.jboss.netty.channel.Channels.pipeline;
  import openr66.protocol.configuration.Configuration;
  
  import org.jboss.netty.channel.ChannelPipeline;
  import org.jboss.netty.channel.ChannelPipelineFactory;
  import org.jboss.netty.handler.codec.http.HttpChunkAggregator;
  import org.jboss.netty.handler.codec.http.HttpContentCompressor;
  import org.jboss.netty.handler.codec.http.HttpRequestDecoder;
  import org.jboss.netty.handler.codec.http.HttpResponseEncoder;
  import org.jboss.netty.handler.execution.ExecutionHandler;
  
  /**
   * Pipeline Factory for HTTP support
   * @author Frederic Bregier
   *
   */
  public class HttpPipelineFactory implements ChannelPipelineFactory {
      public boolean useHttpCompression = false;
      public HttpPipelineFactory(boolean useHttpCompression) {
          this.useHttpCompression = useHttpCompression;
      }
      public ChannelPipeline getPipeline() throws Exception {
          // Create a default pipeline implementation.
          ChannelPipeline pipeline = pipeline();
  
          pipeline.addLast("decoder", new HttpRequestDecoder());
          pipeline.addLast("aggregator", new HttpChunkAggregator(1048576));
          pipeline.addLast("encoder", new HttpResponseEncoder());
          pipeline.addLast("pipelineExecutor", new ExecutionHandler(
                  Configuration.configuration.getHttpPipelineExecutor()));
          if (useHttpCompression) {
              pipeline.addLast("deflater", new HttpContentCompressor());
          }
          pipeline.addLast("handler", new HttpFormattedHandler());
          return pipeline;
      }
  }