From 7890888e805e765ca69d9735f7036cbb8c414170 Mon Sep 17 00:00:00 2001 From: Andrew Mirsky Date: Sat, 7 Jun 2025 17:35:15 -0400 Subject: [PATCH] fixes Yakifo/amqtt#144 : reconnect_retries < 0 will retry indefinitely. consistent default for 'reconnect_retries' --- amqtt/client.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/amqtt/client.py b/amqtt/client.py index 8da9aba..bf51264 100644 --- a/amqtt/client.py +++ b/amqtt/client.py @@ -219,7 +219,7 @@ class MQTTClient: self.logger.debug(f"Reconnecting with session parameters: {self.session}") reconnect_max_interval = self.config.get("reconnect_max_interval", 10) - reconnect_retries = self.config.get("reconnect_retries", 5) + reconnect_retries = self.config.get("reconnect_retries", 2) nb_attempt = 1 while True: @@ -232,7 +232,7 @@ class MQTTClient: except Exception as e: self.logger.warning(f"Reconnection attempt failed: {e!r}") self.logger.debug("", exc_info=True) - if reconnect_retries < nb_attempt: # reconnect_retries >= 0 and + if 0 <= reconnect_retries < nb_attempt: self.logger.exception("Maximum connection attempts reached. Reconnection aborted.") self.logger.debug("", exc_info=True) msg = "Too many failed attempts"