andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Code cleanup

Browse Source
This commit is contained in:
Trustin Lee 2009-03-04 14:17:35 +00:00
parent 1781e0e1dd
commit dfd9669797
1 changed files with 34 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
src/main/java/org/jboss/netty/example/securechat/SecureChatServerHandler.java
View File

@ -77,26 +77,7 @@ public class SecureChatServerHandler extends SimpleChannelHandler {
// Get notified when SSL handshake is done.
ChannelFuture handshakeFuture = sslHandler.handshake(e.getChannel());
handshakeFuture.addListener(new ChannelFutureListener() {
public void operationComplete(ChannelFuture future) throws Exception {
if (future.isSuccess()) {
// Once session is secured, send a greeting.
future.getChannel().write(
"Welcome to " + InetAddress.getLocalHost().getHostName() +
" secure chat service!\n");
future.getChannel().write(
"Your session is protected by " +
sslHandler.getEngine().getSession().getCipherSuite() +
" cipher suite.\n");
// Register the channel to the global channel list
// so the channel received the messages from others.
channels.add(future.getChannel());
} else {
future.getChannel().close();
}
}
});
handshakeFuture.addListener(new Greeter(sslHandler));
}
@Override
@ -137,4 +118,37 @@ public class SecureChatServerHandler extends SimpleChannelHandler {
e.getCause());
e.getChannel().close();
}
/**
* @author The Netty Project (netty-dev@lists.jboss.org)
* @author Trustin Lee (tlee@redhat.com)
* @version $Rev$, $Date$
*/
private static final class Greeter implements ChannelFutureListener {
private final SslHandler sslHandler;
Greeter(SslHandler sslHandler) {
this.sslHandler = sslHandler;
}
public void operationComplete(ChannelFuture future) throws Exception {
if (future.isSuccess()) {
// Once session is secured, send a greeting.
future.getChannel().write(
"Welcome to " + InetAddress.getLocalHost().getHostName() +
" secure chat service!\n");
future.getChannel().write(
"Your session is protected by " +
sslHandler.getEngine().getSession().getCipherSuite() +
" cipher suite.\n");
// Register the channel to the global channel list
// so the channel received the messages from others.
channels.add(future.getChannel());
} else {
future.getChannel().close();
}
}
}
}