diff --git a/playbooks/files/scripts/mqtt_srv.py b/playbooks/files/scripts/mqtt_srv.py
index eab29ea..d126652 100644
--- a/playbooks/files/scripts/mqtt_srv.py
+++ b/playbooks/files/scripts/mqtt_srv.py
@@ -924,7 +924,10 @@ def on_message(client, userdata, msg):
     except:
         print("not a json!")
 
-client = mqtt.Client()
+try:
+    client = mqttClient.Client(mqttClient.CallbackAPIVersion.VERSION1)
+except:
+    client = mqttClient.Client()
 payload = "off"
 client.username_pw_set("jaydee", password="jaydee1")
 client.will_set("sectorq/systems/" + host.lower() + "/stat", payload=payload, qos=0, retain=True)