From b77bdb0837ab2a97780fdbb8b643ea80ec01c495 Mon Sep 17 00:00:00 2001
From: root <hongyuanhua@changeself.com>
Date: Fri, 15 Aug 2025 09:59:30 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E4=BC=98=E5=85=88=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E9=98=9F=E5=88=97=E8=AF=AF=E5=88=A4=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/core/websocket/send_controller.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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: