ISPN-8900 Make sure sockets are closed if can't connect

infinispan · Mar 2, 2018 · 82ea10d · 82ea10d
1 parent 3409d1b
commit 82ea10d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...od-client/src/main/java/org/infinispan/client/hotrod/impl/transport/tcp/TcpTransport.java b/...od-client/src/main/java/org/infinispan/client/hotrod/impl/transport/tcp/TcpTransport.java
@@ -91,6 +91,7 @@ public TcpTransport(SocketAddress originalServerAddress, TransportFactory transp
       } catch (Exception e) {
          String message = String.format("Could not connect to server: %s", serverAddress);
          log.tracef(e, "Could not connect to server: %s", serverAddress);
+         destroy(); // Destroy just to avoid leaking open sockets
          throw new TransportException(message, e, serverAddress);
       }
    }