diff --git a/im-center-server/src/main/java/cn/axzo/im/group/GroupManager.java b/im-center-server/src/main/java/cn/axzo/im/group/GroupManager.java index e38b9a3..7079bcf 100644 --- a/im-center-server/src/main/java/cn/axzo/im/group/GroupManager.java +++ b/im-center-server/src/main/java/cn/axzo/im/group/GroupManager.java @@ -80,7 +80,9 @@ public class GroupManager { group = groupDao.getById(group.getId()); groupBroadcaster.fireGroupChanged(group, MqEventType.GROUP_CREATED); groupMemberSyncer.syncMembers(group); - groupBroadcaster.fireMembersChanged(group, groupMemberDao.getByTid(nimResponse.getTid()), MqEventType.GROUP_ADD_MEMBERS); + groupBroadcaster.fireMembersChanged(group, + groupMemberDao.getByTid(nimResponse.getTid()), + MqEventType.GROUP_ADD_MEMBERS); GroupCreateResponse response = new GroupCreateResponse(); response.setTid(nimResponse.getTid()); response.setAccountsNotFound(imAccounts.getAccountNotFoundPersons( @@ -132,8 +134,7 @@ public class GroupManager { BizAssertions.assertTrue(nimResponse.isSuccess(), "添加群成员失败: {}", nimResponse.getDesc()); // sync members 2 groupMemberSyncer.syncMembers(group); - groupBroadcaster.fireMembersChanged( - group, + groupBroadcaster.fireMembersChanged(group, groupMemberDao.getByPersons(group.getTid(), toAddMembers), MqEventType.GROUP_ADD_MEMBERS); GroupAddMembersResponse response = new GroupAddMembersResponse(); @@ -164,8 +165,8 @@ public class GroupManager { log.info("移除群成员, request={}, response={}", nimRequest, nimResponse); groupMemberSyncer.syncMembers(group); // 不比较直接发消息 - groupBroadcaster.fireMembersChanged( - group, toRemoveMembers, MqEventType.GROUP_REMOVE_MEMBERS); + groupBroadcaster.fireMembersChanged(group, + toRemoveMembers, MqEventType.GROUP_REMOVE_MEMBERS); } @NotNull