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

This should be volatile anyhow

Browse Source
This commit is contained in:
Trustin Lee 2010-02-19 09:08:01 +00:00
parent 0066f9c3ff
commit 28bac1978f
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/jboss/netty/example/localtime/LocalTimeClientHandler.java
View File

@ -49,7 +49,7 @@ public class LocalTimeClientHandler extends SimpleChannelUpstreamHandler {
LocalTimeClientHandler.class.getName()); LocalTimeClientHandler.class.getName());
// Stateful properties // Stateful properties
private Channel channel; private volatile Channel channel;
private final BlockingQueue<LocalTimes> answer = new LinkedBlockingQueue<LocalTimes>(); private final BlockingQueue<LocalTimes> answer = new LinkedBlockingQueue<LocalTimes>();
public List<String> getLocalTimes(Collection<String> cities) { public List<String> getLocalTimes(Collection<String> cities) {
@ -106,10 +106,10 @@ public class LocalTimeClientHandler extends SimpleChannelUpstreamHandler {
} }
@Override @Override
public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) public void channelOpen(ChannelHandlerContext ctx, ChannelStateEvent e)
throws Exception { throws Exception {
channel = e.getChannel(); channel = e.getChannel();
super.channelConnected(ctx, e); super.channelOpen(ctx, e);
} }
@Override @Override