diff --git a/fasta2a/task_manager.py b/fasta2a/task_manager.py
index 54ab709..ed04241 100644
--- a/fasta2a/task_manager.py
+++ b/fasta2a/task_manager.py
@@ -120,7 +120,12 @@ async def send_message(self, request: SendMessageRequest) -> SendMessageResponse
 
         task = await self.storage.submit_task(context_id, message)
 
-        broker_params: TaskSendParams = {'id': task['id'], 'context_id': context_id, 'message': message}
+        broker_params: TaskSendParams = {
+            'id': task['id'],
+            'context_id': context_id,
+            'message': message,
+            'metadata': request['params'].get('metadata', {}),
+        }
         config = request['params'].get('configuration', {})
         history_length = config.get('history_length')
         if history_length is not None: