diff --git a/taskiq/formatters/json_formatter.py b/taskiq/formatters/json_formatter.py
index 012aaa0c..304f0c46 100644
--- a/taskiq/formatters/json_formatter.py
+++ b/taskiq/formatters/json_formatter.py
@@ -16,9 +16,7 @@ def dumps(self, message: TaskiqMessage) -> BrokerMessage:
             task_id=message.task_id,
             task_name=message.task_name,
             message=message.json(),
-            labels={
-                "content_type": "application/json",
-            },
+            labels=message.labels,
         )
 
     def loads(self, message: BrokerMessage) -> TaskiqMessage: