anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

获取被删除群组时总是同步

Browse Source
This commit is contained in:
heavyrian2012
2024-04-28 17:11:36 +08:00
parent 386d0b9c57
commit 1d234a3575
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+1 -1
View File
@@ -2099,7 +2099,7 @@ public class MemoryMessagesStore implements IMessagesStore {
for (WFCMessage.UserRequest request : requests) { for (WFCMessage.UserRequest request : requests) {
WFCMessage.GroupInfo groupInfo = mIMap.get(request.getUid()); WFCMessage.GroupInfo groupInfo = mIMap.get(request.getUid());
if (groupInfo != null && groupInfo.getUpdateDt() > request.getUpdateDt()) { if (groupInfo != null && groupInfo.getUpdateDt() > request.getUpdateDt()) {
if(!isAdmin && !StringUtil.isNullOrEmpty(fromUser)) { if(!isAdmin && !StringUtil.isNullOrEmpty(fromUser) && groupInfo.getDeleted() == 0) {
WFCMessage.GroupMember gm = getGroupMember(groupInfo.getTargetId(), fromUser); WFCMessage.GroupMember gm = getGroupMember(groupInfo.getTargetId(), fromUser);
if((gm == null || gm.getType() == GroupMemberType_Removed) && request.getUpdateDt() > 0) { if((gm == null || gm.getType() == GroupMemberType_Removed) && request.getUpdateDt() > 0) {
continue; continue;