diff --git a/telegram-application/src/core/tg_service/messages_handler.py b/telegram-application/src/core/tg_service/messages_handler.py
index e3e3653..c689744 100644
--- a/telegram-application/src/core/tg_service/messages_handler.py
+++ b/telegram-application/src/core/tg_service/messages_handler.py
@@ -31,10 +31,10 @@ async def message_listener(client: Client, message: Message):
             text=message.text,
             message_time=message.date,
         )
-
-        await check_chunk_state_and_publish(
-            data=DATA,
-            message_schema=message_schema,
-            chat_id=message.chat.id,
-        )
+        async with lock:
+            await check_chunk_state_and_publish(
+                data=DATA,
+                message_schema=message_schema,
+                chat_id=message.chat.id,
+            )