diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java | 2 |
1 files changed, 0 insertions, 2 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java index 0b7d0b303e..12ce46eedb 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java @@ -309,7 +309,6 @@ public class NonBlockingConnection implements NetworkConnection, ByteBufferSende if(_closed.compareAndSet(false,true)) { _protocolEngine.notifyWork(); - getSelector().wakeup(); } } } @@ -628,7 +627,6 @@ public class NonBlockingConnection implements NetworkConnection, ByteBufferSende { throw new SenderClosedException("I/O for thread " + _remoteSocketAddress + " is already closed"); } - // append to list and do selector wakeup _buffers.add(msg); _protocolEngine.notifyWork(); } |