m724/wtapi
1
0
Fork 0
Code Issues 3 Pull requests Projects Releases Packages 1 Wiki Activity Actions

Fix reconnect

Browse source
This commit is contained in:
Minecon724 2025-05-25 17:16:09 +02:00
commit 3e49166308
Signed by untrusted user who does not match committer: m724
GPG key ID: A02E6E67AB961189
3 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/main/java/eu/m724/wtapi/provider/thunder/ThunderProvider.java
View file

@ -9,8 +9,8 @@ public abstract class ThunderProvider {
private final ArrayList<Consumer<TimedStrike>> strikeHandlers = new ArrayList<>(); private final ArrayList<Consumer<TimedStrike>> strikeHandlers = new ArrayList<>();
private final ArrayList<Consumer<ThunderProviderEvent>> eventHandlers = new ArrayList<>(); private final ArrayList<Consumer<ThunderProviderEvent>> eventHandlers = new ArrayList<>();
private long latencyMillis; private long latencyMillis = 0;
private int latencySamplesCount; private int latencySamplesCount = 0;
/** /**
* Connect to the provider and start to process data * Connect to the provider and start to process data

2
src/main/java/eu/m724/wtapi/provider/thunder/impl/blitzortung/BlitzortungProvider.java
View file

@ -43,7 +43,7 @@ public class BlitzortungProvider extends ThunderProvider {
Thread.sleep(3000); Thread.sleep(3000);
submitEvent("Reconnecting"); submitEvent("Reconnecting");
websocketClient.connectBlocking(); websocketClient.reconnectBlocking();
} catch (InterruptedException e) { } catch (InterruptedException e) {
submitEvent("Failed to reconnect", e); submitEvent("Failed to reconnect", e);
} }

2
src/main/java/eu/m724/wtapi/provider/thunder/impl/blitzortung/BlitzortungWebsocketClient.java
View file

@ -82,7 +82,7 @@ class BlitzortungWebsocketClient extends WebSocketClient {
@Override @Override
public void onClose(int code, String reason, boolean remote) { 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]; this.uri = uris[++currentUri % uris.length];
blitzortungProvider.reconnect(); blitzortungProvider.reconnect();