+def mqtt_connect(client, userdata, flags, rc):
+ if debug:
+ print("Connected to MQTT server")
+
+ client.publish("relay/{}/LWT".format(serno_str), "Online", retain=True)
+ print("Subscribing to %s" % prefix.format(serno_str))
+ client.subscribe(prefix.format(serno_str))
+
+