diff --git a/module-instant-message/src/main/java/ink/wgink/module/instantmessage/websocket/handler/text/WebSocketTextHandler.java b/module-instant-message/src/main/java/ink/wgink/module/instantmessage/websocket/handler/text/WebSocketTextHandler.java index ba727fa5..3b23feb7 100644 --- a/module-instant-message/src/main/java/ink/wgink/module/instantmessage/websocket/handler/text/WebSocketTextHandler.java +++ b/module-instant-message/src/main/java/ink/wgink/module/instantmessage/websocket/handler/text/WebSocketTextHandler.java @@ -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);