Class: MqttProvider

MqttProvider(properties)

new MqttProvider(properties)

Build the MqttProvider.
Parameters:
Name Type Description
properties Object the object properties
Properties
Name Type Attributes Default Description
endpoint String the mqtt endpoint[:port]
clientId String the clientId
mqttPrefix String <optional>
'/api' a prefix to each topic
options Object the MQTT.js property options as defined mqtt.Client(streamBuilder, options) Note that the credentials are passed in the object options as for the mqtt.js client.
Source:

Methods

(async) unsubscribe(topic)

Check to unsuscribe to any topic listened by this dsId If the topic is only subscribed by the dsId, unsubscribe from broken Otherwise, remove from the list of subscribe topic/dsId
Parameters:
Name Type Description
topic
Source: