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 static org.jboss.netty.channel.Channels.*;
19
20 import org.jboss.netty.channel.ChannelPipeline;
21 import org.jboss.netty.channel.ChannelPipelineFactory;
22 import org.jboss.netty.handler.codec.compression.ZlibDecoder;
23 import org.jboss.netty.handler.codec.compression.ZlibEncoder;
24 import org.jboss.netty.handler.codec.compression.ZlibWrapper;
25
26
27
28
29 public class FactorialClientPipelineFactory implements
30 ChannelPipelineFactory {
31
32 private final int count;
33
34 public FactorialClientPipelineFactory(int count) {
35 this.count = count;
36 }
37
38 public ChannelPipeline getPipeline() throws Exception {
39 ChannelPipeline pipeline = pipeline();
40
41
42 pipeline.addLast("deflater", new ZlibEncoder(ZlibWrapper.GZIP));
43 pipeline.addLast("inflater", new ZlibDecoder(ZlibWrapper.GZIP));
44
45
46 pipeline.addLast("decoder", new BigIntegerDecoder());
47 pipeline.addLast("encoder", new NumberEncoder());
48
49
50 pipeline.addLast("handler", new FactorialClientHandler(count));
51
52 return pipeline;
53 }
54 }