diff --git a/src/main/java/telraam/station/websocket/WebsocketFetcher.java b/src/main/java/telraam/station/websocket/WebsocketFetcher.java
index 62e9996..3d49016 100644
--- a/src/main/java/telraam/station/websocket/WebsocketFetcher.java
+++ b/src/main/java/telraam/station/websocket/WebsocketFetcher.java
@@ -103,15 +103,6 @@ public void fetch() {
             }
             this.fetch();
         });
-        websocketClient.addOnCloseHandler(() -> {
-            this.logger.severe(String.format("Websocket for station %s got closed", station.getName()));
-            try {
-                Thread.sleep(Fetcher.ERROR_TIMEOUT_MS);
-            } catch (InterruptedException e) {
-                logger.severe(e.getMessage());
-            }
-            this.fetch();
-        });
         websocketClient.addMessageHandler((String msg) -> {
             //Insert detections
             List<Detection> new_detections = new ArrayList<>();