root/fi.utu.tech.powergoblin.api.mqtt/MqttClientHandler

MqttClientHandler

abstract class MqttClientHandler(flags: GenericFlags) : Subsystem

Inheritors

DummyMqttClientHandler

Constructors

MqttClientHandler

constructor(flags: GenericFlags)

Properties

abstract val mqttPrefix: String

abstract val name: String

Name of the source

abstract val server: String

Functions

open fun addCallback(callback: (MQTTMessageEntry) -> Unit)

open fun close()

open fun connect()

open fun init()

Initialize the meter source.

abstract fun sendMqttMsg(prefix: String = mqttPrefix, topic: String, content: String)

sendStatusEvent

open fun sendStatusEvent(event: StatusEvent)

Asynchronous method for broadcasting MQTT status events.

open fun status(): String

Meter source status