JSDoc: Class: MqttQueue

new MqttQueue()

Manages an MQTT queue.

Source:

mqtt-queue.js, line 40

Fires:

Methods

(async) ack(msg) → {Promise.<void>}

Use this if the message is processed successfully.

Parameters:

Name	Type	Description
`msg`	MqttMessage

Source:

mqtt-queue.js, line 242

Throws:

Wrong usage.

Type

Error
SdkError

Returns:

Type: Promise.<void>

(async) close() → {Promise.<void>}

To close the queue. You can use `await` to get the result or listen events.

Source:

mqtt-queue.js, line 182

Throws:

SdkError

Returns:

Type: Promise.<void>

connect()

To connect to the message queue. The `MqttQueue` will report status with Status.

Source:

mqtt-queue.js, line 152

Throws:

Wrong usage.
Type Error

isRecv() → {boolean}

Is the queue a receiver.

Source:

mqtt-queue.js, line 120

Returns:

Type: boolean

(async) nack(msg) → {Promise.<void>}

To requeue the message and the broker will send the message in the future.

Parameters:

Name	Type	Description
`msg`	MqttMessage

Source:

mqtt-queue.js, line 257

Throws:

Wrong usage.

Type

Error
SdkError

Returns:

Type: Promise.<void>

name() → {string}

To get the queue name.

Source:

mqtt-queue.js, line 111

Returns:

Type: string

(async) sendMsg(payload) → {Promise.<void>}

To send a message (for senders only).

Parameters:

Name	Type	Description
`payload`	Buffer	The raw data to be sent.

Source:

mqtt-queue.js, line 215

Throws:

Wrong arguments.

Type

Error
SdkError

Returns:

Type: Promise.<void>

setMsgHandler(handlernullable)

Set the message handler.

Parameters:

Name	Type	Attributes	Description
`handler`	MqttQueueMsgHandler	<nullable>

Source:

mqtt-queue.js, line 139

Throws:

Wrong arguments.
Type Error

status() → {Status}

To get the queue status.

Source:

mqtt-queue.js, line 129

Returns:

Type: Status

Events

error

Queue error event.

Type:

Error

Source:

mqtt-queue.js, line 11

status

Queue status event.

Type:

Status

Source:

mqtt-queue.js, line 18

new MqttQueue(opts, conn)

Parameters:

Name Type Description

opts

Object

The queue options.

Properties

Name	Type	Attributes	Default	Description
`name`	string			The queue name that is used to map a MQTT queue (unicast) or an exchange (broadcast). The pattern is `^[a-z0-9_-]+([\.]{1}[a-z0-9_-]+)*$`.
`isRecv`	boolean			`true` for the receiver and `false` for the sender.
`reliable`	boolean			Reliable by selecting the confirm channel (for publish).
`broadcast`	boolean			`true` for broadcast and `false` for unicast.
`reconnectMillis`	number	<optional>	1000	Time in milliseconds from disconnection to reconnection.
`sharedPrefix`	string	<optional>		OPTIONAL when `isRecv=true`. This is used for unicast.

conn MqttConnection The MQTT connection.