MqttManagerImpl

class MqttManagerImpl(mqttRepository: MQTTRepository, packetHandler: PacketHandler, serviceRepository: ServiceRepository, scope: CoroutineScope) : MqttManager(source)

Constructors

constructor(mqttRepository: MQTTRepository, packetHandler: PacketHandler, serviceRepository: ServiceRepository, scope: CoroutineScope)

open override fun handleMqttProxyMessage(message: MqttClientProxyMessage)

open suspend override fun probe(address: String, tlsEnabled: Boolean, username: String?, password: String?): MqttProbeStatus

open override fun startProxy(enabled: Boolean, proxyToClientEnabled: Boolean)

open override fun stop()