PahoMqttClient

class PahoMqttClient(val client: MqttClient) : DashMqttClient

Constructors

constructor(client: MqttClient)

val client: MqttClient

open override fun close()

open override fun connect()

open override fun isConnected(): Boolean

open override fun publish(topic: String, message: String)

open override fun <T> publish(topic: String, serializer: KSerializer<T>, value: T)

open override fun register(topic: String, listener: DashMqttMessageListener)

open override fun setCallback(callback: DashMqttCallback?)

open override fun subscribe(vararg topics: String)

open override fun unregister(topic: String, listener: DashMqttMessageListener)