This commit is contained in:
2025-06-29 12:37:22 +02:00
parent 7fe7aabd53
commit 6cc2342b20

View File

@@ -31,6 +31,7 @@ class mqtt_sender():
_self.client.connect(_self.broker,_self.port,60)
_self.client.publish(topic, json.dumps(msg))
_self.client.disconnect()
print("Message send")
except ValueError as e:
print("Failed to send")
print(e)
@@ -38,7 +39,7 @@ class mqtt_sender():
mqtt_s = mqtt_sender("mqtt.home.lan", 1883, "jaydee", "l4c1j4yd33Du5lo")
mqtt_s = mqtt_sender("mqtt.home.lan", 1883, "jaydee", "jaydee1")
mqtt_s.send_mqtt_message("sectorq/auto_import/import", {"status": "started"})