diff --git a/src/main/java/org/jboss/netty/channel/local/DefaultLocalChannel.java b/src/main/java/org/jboss/netty/channel/local/DefaultLocalChannel.java index bc7782ede5..0e39600c61 100644 --- a/src/main/java/org/jboss/netty/channel/local/DefaultLocalChannel.java +++ b/src/main/java/org/jboss/netty/channel/local/DefaultLocalChannel.java @@ -67,6 +67,7 @@ final class DefaultLocalChannel extends AbstractChannel implements LocalChannel // TODO Move the state variable to AbstractChannel so that we don't need // to add many listeners. getCloseFuture().addListener(new ChannelFutureListener() { + @Override public void operationComplete(ChannelFuture future) throws Exception { state.set(ST_CLOSED); } diff --git a/src/main/java/org/jboss/netty/channel/socket/nio/NioSocketChannel.java b/src/main/java/org/jboss/netty/channel/socket/nio/NioSocketChannel.java index 925aa42371..12c35ef7ca 100644 --- a/src/main/java/org/jboss/netty/channel/socket/nio/NioSocketChannel.java +++ b/src/main/java/org/jboss/netty/channel/socket/nio/NioSocketChannel.java @@ -87,6 +87,7 @@ class NioSocketChannel extends AbstractChannel // TODO Move the state variable to AbstractChannel so that we don't need // to add many listeners. getCloseFuture().addListener(new ChannelFutureListener() { + @Override public void operationComplete(ChannelFuture future) throws Exception { state = ST_CLOSED; }