michael@0: // Simple subscribe client
michael@0: 
michael@0: //var mqtt = require('mqtt'), locli = mqtt.connect('mqtt://test.mosquitto.org/');
michael@0: //var mqtt = require('mqtt'), locli = mqtt.connect('mqtt://192.168.42.250/');
michael@0: var mqtt = require('mqtt'), locli = mqtt.connect('mqtt://raspeinz.local/');
michael@0: 
michael@0: locli.on('connect', function () {
michael@0:   locli.subscribe('iotmsg');
michael@0: });
michael@0:  
michael@0: locli.on('message', function(topic, message) {
michael@0:   console.log(message.toString());
michael@0:   //locli.end();
michael@0: });
michael@0: 
michael@0: // disable automatic reconnect
michael@0: locli.options.reconnectPeriod = 0;