diff --git a/mqttc.py b/mqttc.py
index 3ae463a..7ec169b 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:
-        save_items(msg.payload)
+        Thread(target=save_items, args=(msg.payload,), daemon=True).start()
 
 def on_disconnect(mqttc: mqtt.Client, userdata, disconnect_flags, reason_code, properties):
     logger.error(f"Disconnected from MQTT broker__:{disconnect_flags}, {reason_code}")