Merge pull request #53 from zt8989/main

Fix #49, change qos 2 to 1, since bemfa not allow qos2
larry-wong · Jul 20, 2024 · 37919b1 · 37919b1
2 parents f87cb83 + 066af8f
commit 37919b1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/custom_components/bemfa/mqtt.py b/custom_components/bemfa/mqtt.py
@@ -54,7 +54,7 @@ def create_sync(self, sync: Sync):
             TOPIC_PUBLISH.format(topic=sync.topic),
             sync.generate_msg(),
         )
-        self._mqttc.subscribe(sync.topic, 2)
+        self._mqttc.subscribe(sync.topic, 1)
 
     def modify_sync(self, sync: Sync):
         """Modify a sync."""
@@ -87,7 +87,7 @@ def connect(self) -> None:
         )
 
         # Listen for heartbeat packages
-        self._mqttc.subscribe(TOPIC_PING, 2)
+        self._mqttc.subscribe(TOPIC_PING, 1)
 
     def _ping(self):
         async def _receive_job():