Zum Inhalt springen
Deutsch

MqttClientLike

Dieser Inhalt ist noch nicht in deiner Sprache verfügbar.

Defined in: src/io/broker/MqttActor.ts:599

Minimal surface of the mqtt.js client we rely on. Exported as a test seam so subclasses overriding MqttActor.mqttModule can satisfy the same shape without the real peer-dep.

end(force?, options?, callback?): void

Defined in: src/io/broker/MqttActor.ts:609

boolean

object

() => void

void


on(event, listener): void

Defined in: src/io/broker/MqttActor.ts:600

"message"

(topic, payload, packet?) => void

void

on(event, listener): void

Defined in: src/io/broker/MqttActor.ts:601

"error"

(err) => void

void

on(event, listener): void

Defined in: src/io/broker/MqttActor.ts:602

"close"

() => void

void


once(event, listener): void

Defined in: src/io/broker/MqttActor.ts:603

"connect"

() => void

void

once(event, listener): void

Defined in: src/io/broker/MqttActor.ts:604

"error"

(err) => void

void


publish(topic, payload, options, callback?): void

Defined in: src/io/broker/MqttActor.ts:606

string

string | Uint8Array<ArrayBufferLike>

MqttPubOpts

(err?) => void

void


removeAllListeners(event?): void

Defined in: src/io/broker/MqttActor.ts:605

string

void


subscribe(topic, options, callback?): void

Defined in: src/io/broker/MqttActor.ts:607

string

MqttQos

(err?) => void

void


unsubscribe(topic, options, callback?): void

Defined in: src/io/broker/MqttActor.ts:608

string

undefined

(err?) => void

void