fix: update reconnection logic to refresh JWT token before connecting

2026-08-05 16:33:40 +02:00 · 2026-01-19 12:41:54 +00:00
parent 371b9fdbb8
commit 33e353d215
1 changed files with 1 additions and 1 deletions
@@ -162,7 +162,7 @@ class _BrokerConnection:
        try:
            logging.info(f"Attempting reconnection to {self.broker['name']}...")
            self.refresh_jwt_token()  # Refresh token before reconnecting
-            self.client.reconnect()
+            self.client.connect(self.broker["host"], self.broker["port"], keepalive=60)
        except Exception as e:
            logging.error(f"Reconnection failed for {self.broker['name']}: {e}")
            self._schedule_reconnect()  # Try again later