Fix logic

mizosoft · May 15, 2024 · 15c5db7 · 15c5db7
1 parent b475922
commit 15c5db7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...testing/src/main/java/com/github/mizosoft/methanol/testing/store/RedisClusterSession.java b/...testing/src/main/java/com/github/mizosoft/methanol/testing/store/RedisClusterSession.java
@@ -205,7 +205,7 @@ public static RedisClusterSession start(int masterCount, int replicasPerMaster)
       } catch (IOException closeEx) {
         e.addSuppressed(closeEx);
       }
-      throw new IOException("Can't operate on started cluster", e);
+      throw new IOException("Started cluster is inoperable", e);
     }
   }
 
@@ -230,7 +230,7 @@ private static void checkHealth(RedisClusterSession cluster) throws InterruptedE
           retriesLeft--;
 
           var message = e.getMessage();
-          if ((message != null && message.contains("CLUSTERDOWN")) || retriesLeft <= 0) {
+          if (message == null || !message.contains("CLUSTERDOWN") || retriesLeft <= 0) {
             throw e;
           }