From 1d577b1b8bd3f51bcf8d9d89bb4598a28020af07 Mon Sep 17 00:00:00 2001 From: Norman Maurer Date: Thu, 11 Jul 2013 11:07:06 +0200 Subject: [PATCH] [#1561] Fix Securechat example which was broken because Channel was not flushed --- .../netty/example/securechat/SecureChatServerHandler.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/example/src/main/java/io/netty/example/securechat/SecureChatServerHandler.java b/example/src/main/java/io/netty/example/securechat/SecureChatServerHandler.java index 5421956af3..0e599fbaf2 100644 --- a/example/src/main/java/io/netty/example/securechat/SecureChatServerHandler.java +++ b/example/src/main/java/io/netty/example/securechat/SecureChatServerHandler.java @@ -47,10 +47,10 @@ public class SecureChatServerHandler extends SimpleChannelInboundHandler new GenericFutureListener>() { @Override public void operationComplete(Future future) throws Exception { - ctx.write( + ctx.writeAndFlush( "Welcome to " + InetAddress.getLocalHost().getHostName() + " secure chat service!\n"); - ctx.write( + ctx.writeAndFlush( "Your session is protected by " + ctx.pipeline().get(SslHandler.class).engine().getSession().getCipherSuite() + " cipher suite.\n"); @@ -65,10 +65,10 @@ public class SecureChatServerHandler extends SimpleChannelInboundHandler // Send the received message to all channels but the current one. for (Channel c: channels) { if (c != ctx.channel()) { - c.write("[" + ctx.channel().remoteAddress() + "] " + + c.writeAndFlush("[" + ctx.channel().remoteAddress() + "] " + msg + '\n'); } else { - c.write("[you] " + msg + '\n'); + c.writeAndFlush("[you] " + msg + '\n'); } }