diff --git a/mqttc.py b/mqttc.py
index 7ec169b..86b9a73 100644
--- a/mqttc.py
+++ b/mqttc.py
@@ -90,7 +90,7 @@ def on_connect(mqttc: mqtt.Client, userdata, flags, rc, properties):
 def on_message(mqttc: mqtt.Client, userdata, msg: mqtt.MQTTMessage):
     topic = msg.topic
     if topic == conf.MQTT_TOPIC:
-        Thread(target=save_items, args=(msg.payload,), daemon=True).start()
+        save_items(msg.payload)
 
 def on_disconnect(mqttc: mqtt.Client, userdata, disconnect_flags, reason_code, properties):
     logger.error(f"Disconnected from MQTT broker__:{disconnect_flags}, {reason_code}")
@@ -101,7 +101,7 @@ def start_mqtt():
     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.connect(host=conf.MQTT_HOST, port=conf.MQTT_PORT, keepalive=60*5)
     client.loop_forever()