From 7741928edcc77bbfeb838f8222252b63f2d1c290 Mon Sep 17 00:00:00 2001
From: caoqianming <caoqianming@foxmail.com>
Date: Thu, 13 Jun 2024 11:33:18 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E8=AE=B0=E5=BD=95=E6=8E=89=E7=BA=BF?=
 =?UTF-8?q?=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 mqttc.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/mqttc.py b/mqttc.py
index ac50bb9..cacefd2 100644
--- a/mqttc.py
+++ b/mqttc.py
@@ -92,13 +92,17 @@ 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 start_mqtt():
     client = mqtt.Client(callback_api_version=mqtt.CallbackAPIVersion.VERSION2, client_id='hfnf_105')
     client.on_connect = on_connect
     client.on_message = on_message
+    client.on_disconnect = on_disconnect
     client.connect(host=conf.MQTT_HOST, port=conf.MQTT_PORT)
-    client.loop_forever()
+    client.loop_start()
 
 
 if __name__ == '__main__':