Skip to content

Latest commit

 

History

History
35 lines (23 loc) · 724 Bytes

use_from_nodejs.md

File metadata and controls

35 lines (23 loc) · 724 Bytes

Use from NodeJS

See demo/simple/nodejs.js source code. Run with:

node ./demo/simple/nodejs.js

The code presumes u8-mqtt is able to be imported:

npm install u8-mqtt

import mqtt_client from 'u8-mqtt/esm/node/index.js'

let my_mqtt = mqtt_client()
  .with_tcp('tcp://test.mosquitto.org:1883')
  // or .with_tcp(1883, 'test.mosquitto.org')
  .with_autoreconnect()

await my_mqtt.connect()

my_mqtt.subscribe_topic(
  'u8-mqtt/demo-simple/:topic',
  (pkt, params, ctx) => {
    console.log('topic packet', params, pkt, pkt.json())
  })

await my_mqtt.json_send(
  'u8-mqtt/demo-simple/live',
  { note: 'from NodeJS example',
    live: new Date().toISOString() })