diff --git a/pkg/pipeline/pipelinemgr.py b/pkg/pipeline/pipelinemgr.py
index 79bd4ec6..abf80e16 100644
--- a/pkg/pipeline/pipelinemgr.py
+++ b/pkg/pipeline/pipelinemgr.py
@@ -94,10 +94,9 @@ class RuntimePipeline:
             ):
                 result.user_notice.insert(0, platform_message.At(query.message_event.sender.id))
             if await query.adapter.is_stream_output_supported():
-                print(query.resp_messages[-1])
                 await query.adapter.reply_message_chunk(
                     message_source=query.message_event,
-                    message_id=str(query.resp_messages[-1].resp_message_id),
+                    bot_message=query.resp_messages[-1],
                     message=result.user_notice,
                     quote_origin=query.pipeline_config['output']['misc']['quote-origin'],
                     is_final=[msg.is_final for msg in query.resp_messages][0]
diff --git a/pkg/pipeline/respback/respback.py b/pkg/pipeline/respback/respback.py
index 5683ce92..d83302ed 100644
--- a/pkg/pipeline/respback/respback.py
+++ b/pkg/pipeline/respback/respback.py
@@ -41,10 +41,9 @@ class SendResponseBackStage(stage.PipelineStage):
         # TODO 命令与流式的兼容性问题
         if await query.adapter.is_stream_output_supported():
             is_final = [msg.is_final for msg in query.resp_messages][0]
-            print(query.resp_messages[-1])
             await query.adapter.reply_message_chunk(
                 message_source=query.message_event,
-                message_id=query.resp_messages[-1].resp_message_id,
+                bot_message=query.resp_messages[-1],
                 message=query.resp_message_chain[-1],
                 quote_origin=quote_origin,
                 is_final=is_final,