MqttManagerImpl

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

Constructors

Link copied to clipboard
constructor(mqttRepository: MQTTRepository, packetHandler: PacketHandler, serviceRepository: ServiceRepository, scope: CoroutineScope)

Properties

Link copied to clipboard
open override val mqttConnectionState: StateFlow<MqttConnectionState>

Functions

Link copied to clipboard
open override fun handleMqttProxyMessage(message: MqttClientProxyMessage)
Link copied to clipboard
open suspend override fun probe(address: String, tlsEnabled: Boolean, username: String?, password: String?): MqttProbeStatus
Link copied to clipboard
open override fun startProxy(enabled: Boolean, proxyToClientEnabled: Boolean)
Link copied to clipboard
open override fun stop()