var mqtt = require('mqtt') | |
var settings = { | |
mqttServerUrl : "localhost", | |
port : 18833, | |
topic : "myTopic" | |
} | |
var client = mqtt.connect('mqtt://' + settings.mqttServerUrl + ":" + settings.port); | |
client.on('connect', function () { | |
client.subscribe(settings.topic) | |
console.log("Subscribed topic " + settings.topic); | |
}) | |
client.on('message', function (topic, message) { | |
console.log(message.toString()); | |
}) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment