1 files changed, 6 insertions, 0 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 551d1c5bae..b0dc85eb0b 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
@@ -405,6 +405,12 @@ public class NonBlockingConnection implements NetworkConnection, ByteBufferSende
                             ByteBuffer.allocate(_sslEngine.getSession().getApplicationBufferSize() + 50);
 
                     _status = _sslEngine.unwrap(_netInputBuffer, appInputBuffer);
+                    if (_status.getStatus() == SSLEngineResult.Status.CLOSED)
+                    {
+                        // KW If SSLEngine changes state to CLOSED, what will ever set _closed to true?
+                        LOGGER.debug("SSLEngine closed");
+                    }
+
                     tasksRun = runSSLEngineTasks(_status);
 
                     appInputBuffer.flip();