1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.jboss.netty.example.proxy;
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.channel.socket.ClientSocketChannelFactory;
23
24 public class HexDumpProxyPipelineFactory implements ChannelPipelineFactory {
25
26 private final ClientSocketChannelFactory cf;
27 private final String remoteHost;
28 private final int remotePort;
29
30 public HexDumpProxyPipelineFactory(
31 ClientSocketChannelFactory cf, String remoteHost, int remotePort) {
32 this.cf = cf;
33 this.remoteHost = remoteHost;
34 this.remotePort = remotePort;
35 }
36
37 public ChannelPipeline getPipeline() throws Exception {
38 ChannelPipeline p = pipeline();
39 p.addLast("handler", new HexDumpProxyInboundHandler(cf, remoteHost, remotePort));
40 return p;
41 }
42 }