Revert "schedule reconnect in case of HTTP_GONE"

This reverts commit 45f72ff.
fabric8io · Nov 5, 2019 · be83797 · be83797 · yujiantao · Jul 23, 2020
1 parent 0b455df
commit be83797
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/...lient/src/main/java/io/fabric8/kubernetes/client/dsl/internal/WatchConnectionManager.java b/...lient/src/main/java/io/fabric8/kubernetes/client/dsl/internal/WatchConnectionManager.java
@@ -255,13 +255,17 @@ public void onMessage(WebSocket webSocket, String message) {
             } else if (object instanceof Status) {
               Status status = (Status) object;
 
+              // The resource version no longer exists - this has to be handled by the caller.
               if (status.getCode() == HTTP_GONE) {
-                logger.info("The resource version {} no longer exists. Scheduling a reconnect.", resourceVersion.get());
-                resourceVersion.set(null);
-                scheduleReconnect();
-              } else {
-                logger.error("Error received: {}", status.toString());
+                webSocketRef.set(null); // lose the ref: closing in close() would only generate a Broken pipe
+                // exception
+                // shut down executor, etc.
+                closeEvent(new KubernetesClientException(status));
+                close();
+                return;
               }
+
+              logger.error("Error received: {}", status.toString());
             } else {
               logger.error("Unknown message received: {}", message);
             }