Skip to main content

MqttClientPort

@totemsdk/edge-mqtt


@totemsdk/edge-mqtt / MqttClientPort

Interface: MqttClientPort

Methods

connect()?

optional connect(): Promise<void>

Returns

Promise<void>


disconnect()?

optional disconnect(): Promise<void>

Returns

Promise<void>


onMessage()

onMessage(handler): () => void

Parameters

handler

(message) => void | Promise<void>

Returns

() => void


publish()

publish(topic, payload, options?): Promise<void>

Parameters

topic

string

payload

string | Uint8Array<ArrayBufferLike>

options?

MqttPublishOptions

Returns

Promise<void>


subscribe()

subscribe(topic, options?): Promise<MqttSubscription>

Parameters

topic

string

options?

MqttSubscribeOptions

Returns

Promise<MqttSubscription>


unsubscribe()?

optional unsubscribe(topic): Promise<void>

Parameters

topic

string

Returns

Promise<void>