|
@@ -16,6 +16,7 @@ def on_connect(client, userdata, flags, reason_code, properties):
|
|
|
client.subscribe('Valvola/#',0)
|
|
client.subscribe('Valvola/#',0)
|
|
|
client.subscribe('Status/#',0)
|
|
client.subscribe('Status/#',0)
|
|
|
#client.subscribe('$SYS/#',0)
|
|
#client.subscribe('$SYS/#',0)
|
|
|
|
|
+
|
|
|
topic = 'Status'
|
|
topic = 'Status'
|
|
|
messaggio = json.dumps({'Status':'AvvioMqttClient'})
|
|
messaggio = json.dumps({'Status':'AvvioMqttClient'})
|
|
|
print(client.publish(topic,messaggio))
|
|
print(client.publish(topic,messaggio))
|