CURATOR-720: Stop retry if client is closed

apache · Dec 4, 2024 · 89f19cf · 89f19cf
1 parent 6a27ff0
commit 89f19cf
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/curator-client/src/main/java/org/apache/curator/CuratorZookeeperClient.java b/curator-client/src/main/java/org/apache/curator/CuratorZookeeperClient.java
@@ -399,6 +399,9 @@ void removeParentWatcher(Watcher watcher) {
     public void internalBlockUntilConnectedOrTimedOut() throws InterruptedException {
         long waitTimeMs = connectionTimeoutMs;
         while (!state.isConnected() && (waitTimeMs > 0)) {
+            if (!started.get()) {
+                throw new IllegalStateException("Client is not started");
+            }
             final CountDownLatch latch = new CountDownLatch(1);
             Watcher tempWatcher = new Watcher() {
                 @Override