commit 94de25eb9fb8be6e6deba38a72afcf7b14ce1d0b
author Alex Rudyy <orudyy@apache.org> Wed Feb 13 15:50:56 2019 +0000
committer Alex Rudyy <orudyy@apache.org> Wed Feb 13 23:00:41 2019 +0000
tree 83d9f238f37afbc415527b2fb2f32f21cb089c9f
parent 1727d0ccd67f0b5b7ed3b2b6d2787e734a473586

QPID-8273: [Broker-J] Set notify work on channel reaching end-of-read-stream

broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java

diff --git a/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java b/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java
index 48dcb37..843e3d7 100644
--- a/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java
+++ b/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java
@@ -542,6 +542,7 @@
         if (read == -1)
         {
             _closed.set(true);
+            _protocolEngine.notifyWork();
         }
 
         _partialRead = read != 0;