diff --git a/wis2box-mqtt-metrics-collector/mqtt_metrics_collector.py b/wis2box-mqtt-metrics-collector/mqtt_metrics_collector.py
index b5970817..6817b41e 100644
--- a/wis2box-mqtt-metrics-collector/mqtt_metrics_collector.py
+++ b/wis2box-mqtt-metrics-collector/mqtt_metrics_collector.py
@@ -174,6 +174,7 @@ def sub_mqtt_metrics(client, userdata, msg):
 
 
 def process_buffered_messages():
+    logger.info("Processing buffered messages")
     global message_buffer
 
     with buffer_lock:
@@ -214,6 +215,7 @@ def process_buffered_messages():
 
 # Call this function periodically, e.g., in a separate thread
 def periodic_buffer_processing():
+    logger.info("Starting periodic buffer processing")
     while True:
         process_buffered_messages()
         time.sleep(5)  # Adjust sleep time as needed