View Javadoc

1   /**
2      This file is part of GoldenGate Project (named also GoldenGate or GG).
3   
4      Copyright 2009, Frederic Bregier, and individual contributors by the @author
5      tags. See the COPYRIGHT.txt in the distribution for a full listing of
6      individual contributors.
7   
8      All GoldenGate Project is free software: you can redistribute it and/or 
9      modify it under the terms of the GNU General Public License as published 
10     by the Free Software Foundation, either version 3 of the License, or
11     (at your option) any later version.
12  
13     GoldenGate is distributed in the hope that it will be useful,
14     but WITHOUT ANY WARRANTY; without even the implied warranty of
15     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
16     GNU General Public License for more details.
17  
18     You should have received a copy of the GNU General Public License
19     along with GoldenGate .  If not, see <http://www.gnu.org/licenses/>.
20   */
21  package openr66.protocol.localhandler;
22  
23  import openr66.protocol.configuration.Configuration;
24  import openr66.protocol.localhandler.packet.LocalPacketCodec;
25  
26  import org.jboss.netty.channel.ChannelPipeline;
27  import org.jboss.netty.channel.ChannelPipelineFactory;
28  import org.jboss.netty.channel.Channels;
29  import org.jboss.netty.handler.execution.ExecutionHandler;
30  
31  /**
32   * Pipeline Factory for Local Server
33   * 
34   * @author Frederic Bregier
35   */
36  public class LocalServerPipelineFactory implements ChannelPipelineFactory {
37      @Override
38      public ChannelPipeline getPipeline() throws Exception {
39          final ChannelPipeline pipeline = Channels.pipeline();
40          pipeline.addLast("codec", new LocalPacketCodec());
41          ExecutionHandler handler = new ExecutionHandler(
42                  Configuration.configuration.getLocalPipelineExecutor());
43          pipeline.addLast("pipelineExecutor", handler);
44          pipeline.addLast("handler", new LocalServerHandler());
45          return pipeline;
46      }
47  
48  }