From 38f29e38fcc668171dc05c53d40a36b895c86102 Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: 星期四, 10 十月 2024 13:34:28 +0800
Subject: [PATCH] init
---
ard-work/src/main/java/com/ruoyi/call/listener/MsgListener.java | 5 ++++-
1 files changed, 4 insertions(+), 1 deletions(-)
diff --git a/ard-work/src/main/java/com/ruoyi/call/listener/MsgListener.java b/ard-work/src/main/java/com/ruoyi/call/listener/MsgListener.java
index 32c5f62..ebbecfa 100644
--- a/ard-work/src/main/java/com/ruoyi/call/listener/MsgListener.java
+++ b/ard-work/src/main/java/com/ruoyi/call/listener/MsgListener.java
@@ -6,6 +6,7 @@
import com.ruoyi.utils.websocket.util.WebSocketUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.event.EventListener;
+import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import java.util.HashMap;
@@ -22,12 +23,14 @@
* @Date: 2023骞�09鏈�23鏃�8:37:00
**/
@Component
-@Slf4j
+@Slf4j(topic = "msgListener")
public class MsgListener {
+ @Async("msgExecutor")
@EventListener(MessageEvent.class)
public void ArdCallHistoryEventListener(MessageEvent messageEvent) {
log.debug("鐩戝惉鍒颁細璇濇秷鎭簨浠�:"+messageEvent.getArdCallHistory().getContent());
+ log.debug("鍦ㄧ嚎鐢ㄦ埛鏁伴噺:"+ONLINE_USER_SESSIONS.size());
String targetId=messageEvent.getTargetId();
ArdCallHistory ardCallHistory = messageEvent.getArdCallHistory();
// 鏋勫缓姝ｅ垯琛ㄨ揪寮忔ā寮�
--
Gitblit v1.9.3