admin/AdvisorServer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

补全交互操作

Browse Source
This commit is contained in:
easonzhu 2025-02-06 19:12:38 +08:00
parent add8f6dfa1
commit 9604c14dce
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/upchina/group/service/common/GroupMessageService.java
View File

@ -65,11 +65,17 @@ public class GroupMessageService {
*/
@PostConstruct
private void initVideoTopic() {
// 后端群组消息 /admin/group/topic/{groupId}
adminGroupTopic = initTopic(CacheKey.GroupMessageTopicKey.ADMIN_GROUP_TOPIC, ADMIN_GROUP_TOPIC, true, false, false);
adminPrivateTopic = initTopic(CacheKey.GroupMessageTopicKey.ADMIN_PRIVATE_TOPIC, ADMIN_PRIVATE_TOPIC, true, true, false);
// 后端私聊消息 /admin/private/topic/{groupId}
adminPrivateTopic = initTopic(CacheKey.GroupMessageTopicKey.ADMIN_PRIVATE_TOPIC, ADMIN_PRIVATE_TOPIC, true, false, false);
// 后端会话消息 /admin/session/topic/{userId}/{sessionId}
adminSessionTopic = initTopic(CacheKey.GroupMessageTopicKey.ADMIN_SESSION_TOPIC, ADMIN_SESSION_TOPIC, false, true, true);
// APP端群组消息 /app/group/topic/{groupId}
appGroupTopic = initTopic(CacheKey.GroupMessageTopicKey.APP_GROUP_TOPIC, APP_GROUP_TOPIC, true, false, false);
// APP端私聊消息 /app/private/topic/{groupId}/{userId}
appPrivateTopic = initTopic(CacheKey.GroupMessageTopicKey.APP_PRIVATE_TOPIC, APP_PRIVATE_TOPIC, true, true, false);
// APP端会话消息 /app/session/topic/{userId}/{sessionId}
appSessionTopic = initTopic(CacheKey.GroupMessageTopicKey.APP_SESSION_TOPIC, APP_SESSION_TOPIC, false, true, true);
}