MqttCommunicator

class MqttCommunicator(brokerUrl: String, scope: CoroutineScope, retrier: Retrier)

Constructors

Link copied to clipboard
constructor(brokerUrl: String, scope: CoroutineScope, retrier: Retrier)

Properties

Link copied to clipboard
val client: IMqttClient

Functions

Link copied to clipboard
fun connect()
Link copied to clipboard
Link copied to clipboard
fun emitToQueue(requireBeingConnected: Boolean = true, shouldRetry: Boolean = false, action: () -> Boolean)