From 28bac1978fd2e0f8ec659481747a8c1b70f50c1e Mon Sep 17 00:00:00 2001 From: Trustin Lee Date: Fri, 19 Feb 2010 09:08:01 +0000 Subject: [PATCH] This should be volatile anyhow --- .../netty/example/localtime/LocalTimeClientHandler.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/jboss/netty/example/localtime/LocalTimeClientHandler.java b/src/main/java/org/jboss/netty/example/localtime/LocalTimeClientHandler.java index b4498e24ac..e2e7109685 100644 --- a/src/main/java/org/jboss/netty/example/localtime/LocalTimeClientHandler.java +++ b/src/main/java/org/jboss/netty/example/localtime/LocalTimeClientHandler.java @@ -49,7 +49,7 @@ public class LocalTimeClientHandler extends SimpleChannelUpstreamHandler { LocalTimeClientHandler.class.getName()); // Stateful properties - private Channel channel; + private volatile Channel channel; private final BlockingQueue answer = new LinkedBlockingQueue(); public List getLocalTimes(Collection cities) { @@ -106,10 +106,10 @@ public class LocalTimeClientHandler extends SimpleChannelUpstreamHandler { } @Override - public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) + public void channelOpen(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception { channel = e.getChannel(); - super.channelConnected(ctx, e); + super.channelOpen(ctx, e); } @Override