cannotReconnect returns false when the watcher is auto-reconnecting

fabric8io · Apr 21, 2021 · a810d42 · a810d42
1 parent 3ae2b55
commit a810d42
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/AbstractWatchManager.java b/...-client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/AbstractWatchManager.java
@@ -121,7 +121,7 @@ void schedule(Runnable command, long delay, TimeUnit timeUnit) {
   }
 
   final boolean cannotReconnect() {
-    return currentReconnectAttempt.get() >= reconnectLimit && reconnectLimit >= 0;
+    return !watcher.reconnecting() && currentReconnectAttempt.get() >= reconnectLimit && reconnectLimit >= 0;
   }
 
   final long nextReconnectInterval() {