fix client not reconnecting

Author: bj00rn

src/publisher/mqtt_publisher.py

@@ -77,6 +77,12 @@ async def __run_loop(self) -> None:
         reconnect_interval = 5
         while True:
             try:
+                LOG.debug(
+                    "Connecting to %s:%s as %s",
+                    self.host,
+                    self.port,
+                    self.publisher_id,
+                )
                 async with client:
                     self.__connected.set()
                     await self.__on_connect()
@@ -88,17 +94,19 @@ async def __run_loop(self) -> None:
                             message.qos,
                             message.properties,
                         )
-            except aiomqtt.MqttError as e:
+            except aiomqtt.MqttError:
                 LOG.error(
-                    f"Connection to MQTT broker lost; Reconnecting in {reconnect_interval} seconds ...: {e}"
+                    "Connection to %s:%s lost; Reconnecting in %d seconds ...",
+                    self.host,
+                    self.port,
+                    reconnect_interval,
                 )
                 await asyncio.sleep(reconnect_interval)
             except asyncio.exceptions.CancelledError:
                 LOG.debug("MQTT publisher loop cancelled")
                 raise
             finally:
                 self.__connected.clear()
-                self.client = None
                 LOG.info("MQTT client disconnected")
 
     @override