1 files changed, 3 insertions, 1 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java
index d4b5975e54..5b714434d9 100644
--- a/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java
+++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java
@@ -33,6 +33,8 @@ import java.net.SocketException;
 import java.nio.ByteBuffer;
 import java.util.concurrent.atomic.AtomicBoolean;
 
+import javax.net.ssl.SSLSocket;
+
 /**
  * IoReceiver
  *
@@ -94,7 +96,7 @@ final class IoReceiver implements Runnable, Closeable
             {
                 try
                 {
-                    if (shutdownBroken)
+                    if (shutdownBroken || socket instanceof SSLSocket)
                     {
                        socket.close();
                     }