KMQTTHandler

class KMQTTHandler(flags: GenericFlags, host: String, port: Int, val mqttPrefix: String, retryPeriod: Long = 500, shutdownDelay: Long = 500) : MqttClientHandler

Constructors

constructor(flags: GenericFlags, host: String, port: Int, mqttPrefix: String, retryPeriod: Long = 500, shutdownDelay: Long = 500)

inner class Worker

open override val mqttPrefix: String

open override val name: String

Name of the source

open override val server: String

open override fun close()

open override fun connect()

Start the MQTT client. The host and port of the message broker are provided as parameters.

open fun init()

Initialize the meter source.

open override fun sendMqttMsg(prefix: String, topic: String, content: String)

Simply send a MQTT message, using the provided topic and message payload (string).

Asynchronous method for broadcasting MQTT status events.

open override fun status(): String

Meter source status

open override fun toString(): String