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() })