Tenlion/wg-basic
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新增不同类型消息

Browse Source
This commit is contained in:
wanggeng 2021-11-17 23:27:15 +08:00
parent a6e12e7d47
commit 644d25b07f
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
module-instant-message/src/main/java/ink/wgink/module/instantmessage/websocket/handler/text/WebSocketTextHandler.java
View File

@ -63,6 +63,16 @@ public class WebSocketTextHandler {
} else if (MessageTypeEnum.MESSAGE_GROUP.getValue() == clientSocketMessage.getType()) {
// 群发消息
sendGroupText(ctx.channel(), clientSocketMessage);
} else if (MessageTypeEnum.MESSAGE_GROUP_HREF.getValue() == clientSocketMessage.getType()) {
sendGroupText(ctx.channel(), clientSocketMessage);
} else if (MessageTypeEnum.MESSAGE_GROUP_IMAGE.getValue() == clientSocketMessage.getType()) {
sendGroupText(ctx.channel(), clientSocketMessage);
} else if (MessageTypeEnum.MESSAGE_GROUP_FILE.getValue() == clientSocketMessage.getType()) {
sendGroupText(ctx.channel(), clientSocketMessage);
} else if (MessageTypeEnum.MESSAGE_GROUP_AUDIO.getValue() == clientSocketMessage.getType()) {
sendGroupText(ctx.channel(), clientSocketMessage);
} else if (MessageTypeEnum.MESSAGE_GROUP_VIDEO.getValue() == clientSocketMessage.getType()) {
sendGroupText(ctx.channel(), clientSocketMessage);
} else if (MessageTypeEnum.SEARCH_ONLINE_USER.getValue() == clientSocketMessage.getType()) {
// 用户在线状态
listOnlineUser(ctx.channel(), clientSocketMessage);