a

app.py

@@ -20,6 +20,7 @@ def create_client(host, port, username, password):
     client.username_pw_set(username, password)
     client.tls_set(tls_version=mqtt.ssl.PROTOCOL_TLS)
     client.on_connect = on_connect
+    client.on_message = on_message
     client.connect(host, port)
     client.loop_start()
     return client