Fix paho-mqtt new versions

bkbilly · Mar 30, 2024 · 8f6d24b · 8f6d24b
1 parent 5f7beed
commit 8f6d24b
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/alarmcode/notifier.py b/alarmcode/notifier.py
@@ -119,7 +119,10 @@ def setupMQTT(self):
 
         # self.mqttclient = mqtt.Client("", True, None, mqtt.MQTTv311)
         if not hasattr(self, 'mqttclient'):
-            self.mqttclient = mqtt.Client(client_id=str(random.randint(1,10000)), clean_session=False)
+            if hasattr(mqtt, "CallbackAPIVersion"):
+                self.mqttclient = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
+            else:
+                self.mqttclient = mqtt.Client(client_id=str(random.randint(1,10000)), clean_session=False)
 
         self.mqttclient.disconnect()
         self.mqttclient.loop_stop(force=False)