smart_garden_server/server/mqtt_test.js
2020-06-29 13:31:36 +02:00

16 lines
437 B
JavaScript

const mqtt = require('mqtt')
const client = mqtt.connect('mqtt://mqtt.timovolkmann.de')
client.on('connect', function () {
client.subscribe('smartgarden/updates', function (err) {
if (!err) {
client.publish('smartgarden/updates', 'Hello mqtt')
}
})
})
client.on('message', function (topic, message) {
// message is Buffer
console.log('topic:', topic.toString(), 'message:', message.toString())
//client.end()
})