diff --git a/plugins/ai_auto_response/main.py b/plugins/ai_auto_response/main.py index 6edcafe..4d1569a 100644 --- a/plugins/ai_auto_response/main.py +++ b/plugins/ai_auto_response/main.py @@ -216,7 +216,8 @@ class AIAutoResponsePlugin(MessagePluginInterface): sender=sender, queue_size=self.message_queue.qsize(), ) - return True, "queued" + # 非阻断模式:放入异步队列后,不拦截后续插件执行 + return False, "queued" except asyncio.QueueFull: self._log_event( "drop", @@ -225,7 +226,8 @@ class AIAutoResponsePlugin(MessagePluginInterface): reason="queue_full", queue_maxsize=self.queue_maxsize, ) - return True, "queue_full" + # 队列满也不阻断后续插件,让其他插件继续尝试处理 + return False, "queue_full" async def _process_message_impl(self, message: Dict[str, Any]) -> Tuple[bool, Optional[str]]: room_id = message.get("roomid", "")