Client Module

class mtf.utils.mqtt.client.MtfMqttClient

client_id

rec_messages

on_message_callbacks

__init__(broker: str = '127.0.0.1', port: int = 1883, topic: str = 'mtf', username: str = '', password: str = '')

broker

port

topic

username

password

connect(broker: str = '127.0.0.1', port: int = 1883, topic: str = 'mtf', username: str = '', password: str = '')

on_connect(client, userdata, flags, rc)

subscribe(topics)

on_disconnect(client, userdata, rc)

register_on_message_callback(topic, callback)

on_message(userdata, msg)

publish(msg: str, topic: str | None = None)

client_loop_forever()

client_loop_start()

client_loop_stop(force=False)