var mqtt = require('mqtt');

var clt = mqtt.connect("mqtt://osak-3.local:1885", {port: 1885, protocol: "ws"})


clt.on('connect', function () { console.log("connected"); })
clt.on('disconnect', function () { console.log("disconnected");})

clt.subscribe("default/test")

clt.on('message', function (topic, message) {
    console.log(topic, message.length, message)
})

setInterval(function(){
    console.log("client ok", clt.connected)
}, 5000);