mqtt connect

mqtt.connect.js

/**
 * usage node connect.js mqtt://localhost:1883
 */


const mqtt = require('mqtt')

const URI = process.argv[2]

const EVENTS = ['connect', 'reconnect', 'close', 'offline', 'end', 'error', 'packetsend', 'packetreceive', 'message']

console.log('CONNECTING', URI)
let client = mqtt.connect(
  URI,
  {keepalive: 120 + Math.round(Math.random() * 100)}
)

EVENTS.forEach(eventName => {
  client.on(eventName, data => console.log(eventName, JSON.stringify(data)))
})

client.subscribe('#')