tuxeatpi_common.message module

Module defining TuxEatPi Messages

class tuxeatpi_common.message.Message(topic, data, context='general', source=None)

Bases: object

MQTT Message class

serialize()

Serialize message content

class tuxeatpi_common.message.MqttClient(component)

Bases: paho.mqtt.client.Client

MQTT client class

on_connect(client, userdata, flags, rc)

Callback on server connect

on_message(mqttc, obj, msg)

Callback on receive message

on_publish(client, userdata, mid)

Callback on message publish

on_subscribe(client, userdata, mid, granted_qos)

Callback on topic subcribing

run()

Run MQTT client

stop()

Stop MQTT client

class tuxeatpi_common.message.MqttSender(component)

Bases: paho.mqtt.client.Client

MQTT client class

run()

Run MQTT client

stop()

Stop MQTT client

tuxeatpi_common.message.is_mqtt_topic(topic_name)

Add a method as a MQTT topic