QPID-8273: [Broker-J] Set notify work on channel reaching end-of-read-stream
authorAlex Rudyy <orudyy@apache.org>
Wed, 13 Feb 2019 15:50:56 +0000 (15:50 +0000)
committerAlex Rudyy <orudyy@apache.org>
Wed, 13 Feb 2019 23:00:41 +0000 (23:00 +0000)
broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java

index 48dcb37..843e3d7 100644 (file)
@@ -542,6 +542,7 @@ public class NonBlockingConnection implements ServerNetworkConnection, ByteBuffe
         if (read == -1)
         {
             _closed.set(true);
+            _protocolEngine.notifyWork();
         }
 
         _partialRead = read != 0;