mqttworker/com.chungha.mqttworker/MqttManager

MqttManager

object MqttManager : MqttListener

MQTT Manager

Properties

Link copied to clipboard
val connectStatusState: StateFlow<MqttConnectStatus>

Get MQTT connection status Flow

Link copied to clipboard
val messageState: StateFlow<MqttMessage>

Get subscription message Flow from callback received

Link copied to clipboard
val messageStateFlow: SharedFlow<MqttMessage>

Functions

Link copied to clipboard
open override fun connect(context: Context, options: MqttClientOptions)

Connect to MQTT

Link copied to clipboard
open override fun disconnect()

Disconnect

Link copied to clipboard
open override fun subscribeListTopic(topics: List<Topic>)

subscribe to MQTT

Link copied to clipboard
open override fun unSubscribeListTopic(topics: List<Topic>)

unsubscribe to MQTT

Link copied to clipboard
fun updateStatusConnect(status: MqttConnectStatus)

Update MQTT connection status