See u8-mqtt-packet for MQTT packet encoding details
-
mqtt.connect(pkt={})
-- Encode and send an MQTT connect packet. All arguments are optional. Returns a promise resolved by theconnack
response packet.If
pkt.client_id
is falsy or an Array,client_id
is initialized withmqtt.init_client_id(pkt.client_id)
If
pkt.keep_alive
is nullish, it is defaulted to60
. After recieving theconnack
reply packet, an automated ping process is started viamqtt._conn_.ping(pkt.keep_alive)
Returns a
Promise<[connack pkt, error]>
in the style of an Option / Maybe monad.See
u8-mqtt-packet/docs/mqtt_codec_connect.md
for MQTT packet encoding details -
mqtt.disconnect(pkt)
-- Encode and send an MQTT disconnect packet. All arguments are optional. Resets the_conn
connection.See
u8-mqtt-packet/docs/mqtt_codec_disconnect.md
for MQTT packet encoding details -
mqtt.auth(pkt)
-- Encode and send an MQTT auth packet.See
u8-mqtt-packet/docs/mqtt_codec_auth.md
for MQTT packet encoding detailsFor default
{username, password}
authentication methods usemqtt.connect({username, password})
. -
mqtt.ping()
-- Encode and send an MQTT pingreq packet. Returns a promise that is resolved after apingresp
packet is received.Note that
mqtt.connect
automatically pings the MQTT server based onkeep_alive
setting.Returns a
Promise<[pingresp pkt, error]>
in the style of an Option / Maybe monad.See
u8-mqtt-packet/docs/mqtt_codec_pingreq_pingresp.md
for MQTT packet encoding details