21 lines
384 B
Python
21 lines
384 B
Python
import paho.mqtt.client as mqtt
|
|
|
|
|
|
def on_message(client, userdata, message):
|
|
print(str(message.payload.decode("utf-8")))
|
|
|
|
client.publish("/repeat/", message.payload)
|
|
|
|
|
|
mqttBroker = 'icyn30.duckdns.org'
|
|
mqttPort = 1888
|
|
|
|
client = mqtt.Client("Notifier")
|
|
|
|
client.connect(mqttBroker, mqttPort)
|
|
|
|
client.subscribe("/Test/test")
|
|
client.on_message = on_message
|
|
|
|
client.loop_forever()
|