1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.jboss.netty.example.factorial;
17
18 import org.jboss.netty.channel.ChannelPipeline;
19 import org.jboss.netty.channel.ChannelPipelineFactory;
20 import org.jboss.netty.handler.codec.compression.ZlibDecoder;
21 import org.jboss.netty.handler.codec.compression.ZlibEncoder;
22 import org.jboss.netty.handler.codec.compression.ZlibWrapper;
23 import org.jboss.netty.handler.ssl.SslContext;
24
25 import static org.jboss.netty.channel.Channels.*;
26
27
28
29
30 public class FactorialServerPipelineFactory implements ChannelPipelineFactory {
31
32 private final SslContext sslCtx;
33
34 public FactorialServerPipelineFactory(SslContext sslCtx) {
35 this.sslCtx = sslCtx;
36 }
37
38 public ChannelPipeline getPipeline() {
39 ChannelPipeline pipeline = pipeline();
40
41 if (sslCtx != null) {
42 pipeline.addLast("ssl", sslCtx.newHandler());
43 }
44
45
46 pipeline.addLast("deflater", new ZlibEncoder(ZlibWrapper.GZIP));
47 pipeline.addLast("inflater", new ZlibDecoder(ZlibWrapper.GZIP));
48
49
50 pipeline.addLast("decoder", new BigIntegerDecoder());
51 pipeline.addLast("encoder", new NumberEncoder());
52
53
54
55
56 pipeline.addLast("handler", new FactorialServerHandler());
57
58 return pipeline;
59 }
60 }