Merge pull request #57 from AndrewLaptev/patch-1

Missing MQTTConfig in __set_connetion_config
sabuhish · May 21, 2023 · 2f77614 · 2f77614
2 parents 7d67ad6 + c06bb71
commit 2f77614
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/fastapi_mqtt/fastmqtt.py b/fastapi_mqtt/fastmqtt.py
@@ -138,8 +138,8 @@ async def __set_connetion_config(self) -> None:
         For more info: https://github.com/wialon/gmqtt#reconnects
         """
         self.client.set_config({
-            "reconnect_retries":self.reconnect_retries, 
-            "reconnect_delay": self.reconnect_delay})
+            "reconnect_retries":self.config.reconnect_retries,
+            "reconnect_delay": self.config.reconnect_delay})
 
     def __on_connect(self, client, flags, rc, properties) -> None:
         """