ISPN-4083 Do not invalidate null Transport

maniksurtani · Apr 4, 2014 · 8f6b0a7 · 8f6b0a7
1 parent 547f52f
commit 8f6b0a7
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...t/src/main/java/org/infinispan/client/hotrod/impl/operations/RetryOnFailureOperation.java b/...t/src/main/java/org/infinispan/client/hotrod/impl/operations/RetryOnFailureOperation.java
@@ -54,8 +54,10 @@ public T execute() {
             failedServers.add(te.getServerAddress());
             // Invalidate transport since this exception means that this
             // instance is no longer usable and should be destroyed.
-            transportFactory.invalidateTransport(
-                  te.getServerAddress(), transport);
+            if (transport != null) {
+               transportFactory.invalidateTransport(
+                     te.getServerAddress(), transport);
+            }
             logErrorAndThrowExceptionIfNeeded(retryCount, te);
          } catch (RemoteNodeSuspectException e) {
             // Do not invalidate transport because this exception is caused