diff --git a/mqttc.py b/mqttc.py index df392cb..3ae463a 100644 --- a/mqttc.py +++ b/mqttc.py @@ -92,8 +92,8 @@ def on_message(mqttc: mqtt.Client, userdata, msg: mqtt.MQTTMessage): if topic == conf.MQTT_TOPIC: save_items(msg.payload) -def on_disconnect(mqttc: mqtt.Client, userdata, rc): - logger.error("Disconnected from MQTT broker") +def on_disconnect(mqttc: mqtt.Client, userdata, disconnect_flags, reason_code, properties): + logger.error(f"Disconnected from MQTT broker__:{disconnect_flags}, {reason_code}") def start_mqtt():