Fix for REM3-250. Close SSLConnection

dmlloyd · Dec 1, 2016 · 61b0b9e · 61b0b9e
1 parent aad680f
commit 61b0b9e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/main/java/org/jboss/remoting3/remote/RemoteConnectionProvider.java b/src/main/java/org/jboss/remoting3/remote/RemoteConnectionProvider.java
@@ -264,6 +264,8 @@ public void handleDone(final StreamConnection streamConnection, final FutureResu
                     return;
                 }
                 final JsseSslConnection sslConnection = new JsseSslConnection(streamConnection, engine);
+                // Required in order for the SSLConnection to be properly closed.
+                streamConnection.getCloseSetter().set(channel -> IoUtils.safeClose(sslConnection));
                 if (sslRequired || ! connectOptions.get(Options.SSL_STARTTLS, false)) try {
                     sslConnection.startHandshake();
                 } catch (IOException e) {