diff --git a/src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java b/src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java index 98b3850c03..fb5bd95813 100644 --- a/src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java +++ b/src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java @@ -82,7 +82,6 @@ class NioWorker implements Runnable { private final SocketReceiveBufferPool recvBufferPool = new SocketReceiveBufferPool(); private final SocketSendBufferPool sendBufferPool = new SocketSendBufferPool(); - private final AtomicBoolean fireConnect = new AtomicBoolean(true); NioWorker(int bossId, int id, Executor executor) { this.bossId = bossId; @@ -97,7 +96,6 @@ class NioWorker implements Runnable { Selector selector; synchronized (startStopLock) { - fireConnect.set(true); if (!started) { // Open a selector if this worker didn't start yet.