1   
2   
3   
4   
5   
6   
7   
8   
9   
10  
11  
12  
13  
14  
15  
16  package org.jboss.netty.example.http.websocketx.autobahn;
17  
18  import org.jboss.netty.channel.ChannelPipeline;
19  import org.jboss.netty.channel.ChannelPipelineFactory;
20  import org.jboss.netty.handler.codec.http.HttpChunkAggregator;
21  import org.jboss.netty.handler.codec.http.HttpRequestDecoder;
22  import org.jboss.netty.handler.codec.http.HttpResponseEncoder;
23  
24  import static org.jboss.netty.channel.Channels.*;
25  
26  
27  
28  public class AutobahnServerPipelineFactory implements ChannelPipelineFactory {
29      public ChannelPipeline getPipeline() {
30          
31          ChannelPipeline pipeline = pipeline();
32          pipeline.addLast("decoder", new HttpRequestDecoder());
33          pipeline.addLast("aggregator", new HttpChunkAggregator(65536));
34          pipeline.addLast("encoder", new HttpResponseEncoder());
35          pipeline.addLast("handler", new AutobahnServerHandler());
36          return pipeline;
37      }
38  }