mqtt.CallbackAPIVersion.VERSION2

aneisch · Feb 17, 2024 · 18a1f9d · 18a1f9d
1 parent 216c577
commit 18a1f9d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/thermostat_api_server.py b/thermostat_api_server.py
@@ -413,7 +413,7 @@ def do_POST(self):
 class ThreadingSimpleServer(ThreadingMixIn, HTTPServer):
     pass
 
-client = mqttClient.Client(f"thermostat_api_server_{thermostat_serial}")
+client = mqttClient.Client(mqtt.CallbackAPIVersion.VERSION2, f"thermostat_api_server_{thermostat_serial}")
 if "mqtt_username" in locals():
     client.username_pw_set(username=mqtt_username,password=mqtt_password)
 server = ThreadingSimpleServer(('0.0.0.0', 8080), MyHttpRequestHandler)