Reconnect websockets after errors

2021-10-10 13:31:34 +02:00 · 2021-10-10 13:31:34 +02:00 · bfddb40d73
commit bfddb40d73
parent 07742843df
1 changed files with 2 additions and 0 deletions
--- a/lib/src/main/java/org/asamk/signal/manager/SignalWebSocketHealthMonitor.java
+++ b/lib/src/main/java/org/asamk/signal/manager/SignalWebSocketHealthMonitor.java
@ -101,6 +101,7 @@ public final class SignalWebSocketHealthMonitor implements HealthMonitor {
            if (healthState.mismatchErrorTracker.addSample(System.currentTimeMillis())) {
                logger.warn("Received too many mismatch device errors, forcing new websockets.");
                signalWebSocket.forceNewWebSockets();
+                signalWebSocket.connect();
            }
        }
    }
@ -146,6 +147,7 @@ public final class SignalWebSocketHealthMonitor implements HealthMonitor {
                                    + " needed by: "
                                    + keepAliveRequiredSinceTime);
                            signalWebSocket.forceNewWebSockets();
+                            signalWebSocket.connect();
                        } else {
                            signalWebSocket.sendKeepAlive();
                        }