mqtt version 2

chaosdorf · Feb 20, 2024 · a8aaac6 · a8aaac6
1 parent d259fab
commit a8aaac6
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/main.py b/main.py
@@ -10,6 +10,7 @@
 from pathlib import Path
 import json
 from paho.mqtt.client import Client as MqttClient
+from paho.mqtt.client import CallbackAPIVersion as MqttCallbackAPIVersion
 import toml
 
 DSN_PATH = Path("/run/secrets/SIAMQTT_SENTRY_DSN")
@@ -88,7 +89,7 @@ def publish_to_mqtt(self) -> None:
     ],
     handle_event,
 )
-mqtt = MqttClient()
+mqtt = MqttClient(MqttCallbackAPIVersion.VERSION2)
 mqtt.connect(config["mqtt"]["server"])
 
 if "homeassistant" in config["mqtt"]: