fix: eliminate critical message queue blockage in wxoa

This commit is contained in:
wangcham
2025-03-13 10:41:21 -04:00
parent a74111612e
commit 8b4684675e
2 changed files with 26 additions and 9 deletions

View File

@@ -101,13 +101,15 @@ class OfficialAccountAdapter(adapter.MessagePlatformAdapter):
Appsecret=config['AppSecret'],
AppID=config['AppID'],
)
if self.config['Mode'] == "passive":
elif self.config['Mode'] == "passive":
self.bot = OAClientForLongerResponse(
token=config['token'],
EncodingAESKey=config['EncodingAESKey'],
Appsecret=config['AppSecret'],
AppID=config['AppID'],
)
else:
raise KeyError("请设置微信公众号通信模式")
async def reply_message(self, message_source: platform_events.FriendMessage, message: platform_message.MessageChain, quote_origin: bool = False):