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__':