mqtt_connector

qoa4ml.connector.mqtt_connector

Classes

MqttConnector

Publish reports through MQTT and dispatch incoming messages to host_object.

host_object.message_processing(client, userdata, msg) is invoked whenever the broker delivers a message on the subscribed topic. Callers must call :meth:start after construction so paho's network loop is actually running; otherwise publishes will queue locally until the loop drains them.