From 3e491663080e0fcd6c49b662701dc88c5cf6d8b8 Mon Sep 17 00:00:00 2001 From: Minecon724 Date: Sun, 25 May 2025 17:16:09 +0200 Subject: [PATCH] Fix reconnect --- .../java/eu/m724/wtapi/provider/thunder/ThunderProvider.java | 4 ++-- .../thunder/impl/blitzortung/BlitzortungProvider.java | 2 +- .../thunder/impl/blitzortung/BlitzortungWebsocketClient.java | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/eu/m724/wtapi/provider/thunder/ThunderProvider.java b/src/main/java/eu/m724/wtapi/provider/thunder/ThunderProvider.java index 770d7b5..efe12c3 100644 --- a/src/main/java/eu/m724/wtapi/provider/thunder/ThunderProvider.java +++ b/src/main/java/eu/m724/wtapi/provider/thunder/ThunderProvider.java @@ -9,8 +9,8 @@ public abstract class ThunderProvider { private final ArrayList> strikeHandlers = new ArrayList<>(); private final ArrayList> eventHandlers = new ArrayList<>(); - private long latencyMillis; - private int latencySamplesCount; + private long latencyMillis = 0; + private int latencySamplesCount = 0; /** * Connect to the provider and start to process data diff --git a/src/main/java/eu/m724/wtapi/provider/thunder/impl/blitzortung/BlitzortungProvider.java b/src/main/java/eu/m724/wtapi/provider/thunder/impl/blitzortung/BlitzortungProvider.java index f05b5c4..ec4f5a5 100644 --- a/src/main/java/eu/m724/wtapi/provider/thunder/impl/blitzortung/BlitzortungProvider.java +++ b/src/main/java/eu/m724/wtapi/provider/thunder/impl/blitzortung/BlitzortungProvider.java @@ -43,7 +43,7 @@ public class BlitzortungProvider extends ThunderProvider { Thread.sleep(3000); submitEvent("Reconnecting"); - websocketClient.connectBlocking(); + websocketClient.reconnectBlocking(); } catch (InterruptedException e) { submitEvent("Failed to reconnect", e); } diff --git a/src/main/java/eu/m724/wtapi/provider/thunder/impl/blitzortung/BlitzortungWebsocketClient.java b/src/main/java/eu/m724/wtapi/provider/thunder/impl/blitzortung/BlitzortungWebsocketClient.java index 44c40ec..b7b7b21 100644 --- a/src/main/java/eu/m724/wtapi/provider/thunder/impl/blitzortung/BlitzortungWebsocketClient.java +++ b/src/main/java/eu/m724/wtapi/provider/thunder/impl/blitzortung/BlitzortungWebsocketClient.java @@ -82,7 +82,7 @@ class BlitzortungWebsocketClient extends WebSocketClient { @Override public void onClose(int code, String reason, boolean remote) { - blitzortungProvider.wsSubmitEvent("Websocket closed: %s".formatted(reason), null); + blitzortungProvider.wsSubmitEvent("Websocket closed: %d %s".formatted(code, reason), null); this.uri = uris[++currentUri % uris.length]; blitzortungProvider.reconnect();