diff --git a/app/core/websocket/send_controller.py b/app/core/websocket/send_controller.py
index f3a6a2e..b2dac2d 100644
--- a/app/core/websocket/send_controller.py
+++ b/app/core/websocket/send_controller.py
@@ -206,7 +206,7 @@ class WebSocketSendController:
                     message_sent = False
                     
                     # 1. 优先发送业务数据
-                    if self.send_channel.queue_size > 0:
+                    if self.send_channel.total_queue_size > 0:  # 修改这里，使用total_queue_size而不是queue_size
                         try:
                             message = await self.send_channel.receive_message()
                             if message: