1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.jboss.netty.example.securechat;
17
18 import java.util.logging.Level;
19 import java.util.logging.Logger;
20
21 import org.jboss.netty.channel.ChannelEvent;
22 import org.jboss.netty.channel.ChannelHandlerContext;
23 import org.jboss.netty.channel.ChannelStateEvent;
24 import org.jboss.netty.channel.ExceptionEvent;
25 import org.jboss.netty.channel.MessageEvent;
26 import org.jboss.netty.channel.SimpleChannelUpstreamHandler;
27 import org.jboss.netty.handler.ssl.SslHandler;
28
29
30
31
32 public class SecureChatClientHandler extends SimpleChannelUpstreamHandler {
33
34 private static final Logger logger = Logger.getLogger(
35 SecureChatClientHandler.class.getName());
36
37 @Override
38 public void handleUpstream(
39 ChannelHandlerContext ctx, ChannelEvent e) throws Exception {
40 if (e instanceof ChannelStateEvent) {
41 logger.info(e.toString());
42 }
43 super.handleUpstream(ctx, e);
44 }
45
46 @Override
47 public void channelConnected(
48 ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
49
50
51 SslHandler sslHandler = ctx.getPipeline().get(SslHandler.class);
52
53
54 sslHandler.handshake();
55 }
56
57 @Override
58 public void messageReceived(
59 ChannelHandlerContext ctx, MessageEvent e) {
60 System.err.println(e.getMessage());
61 }
62
63 @Override
64 public void exceptionCaught(
65 ChannelHandlerContext ctx, ExceptionEvent e) {
66 logger.log(
67 Level.WARNING,
68 "Unexpected exception from downstream.",
69 e.getCause());
70 e.getChannel().close();
71 }
72 }