spatial-monorepo

spatial-monorepo / core/src / DataBusMQTTAdapter

Class: DataBusMQTTAdapter

Defined in: packages/core/src/transport/databus-mqtt-adapter.ts:12

Implements

DataBusTransportAdapter

Constructors

Constructor

new DataBusMQTTAdapter(bus, url, mapPayload, opts?): DataBusMQTTAdapter

Defined in: packages/core/src/transport/databus-mqtt-adapter.ts:20

Parameters

bus

url

string

mapPayload

DataBusMapPayload

opts?

connectFn?

(url) => MQTTClientLike

topics?

string[]

Returns

DataBusMQTTAdapter

Methods

connect()

connect(): Promise`<void>`

Defined in: packages/core/src/transport/databus-mqtt-adapter.ts:41

Returns

Promise`<void>`

Implementation of

DataBusTransportAdapter.connect

disconnect()

disconnect(): Promise`<void>`

Defined in: packages/core/src/transport/databus-mqtt-adapter.ts:70

Returns

Promise`<void>`

Implementation of

DataBusTransportAdapter.disconnect