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

fix build error

Browse Source
This commit is contained in:
heavyrian2012
2022-11-12 14:18:26 +08:00
parent b2eab28cb9
commit 1275b2109f
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+2 -2
View File
@@ -1439,7 +1439,7 @@ public class MemoryMessagesStore implements IMessagesStore {
} }
return ErrorCode.ERROR_CODE_NOT_EXIST; return ErrorCode.ERROR_CODE_NOT_EXIST;
} }
if(!admin && groupInfo.getType() == ProtoConstants.GroupType.GroupType_Organization) { if(!admin && groupInfo.getType() == ProtoConstants.GroupType.GroupType_Organization) {
return ErrorCode.ERROR_CODE_NOT_RIGHT; return ErrorCode.ERROR_CODE_NOT_RIGHT;
} }
@@ -1486,7 +1486,7 @@ public class MemoryMessagesStore implements IMessagesStore {
int[] removedCount = new int[1]; int[] removedCount = new int[1];
for (String groupId : groupIds) { for (String groupId : groupIds) {
removedCount[0] = 0; removedCount[0] = 0;
ErrorCode errorCode = quitGroup(userId, groupId); ErrorCode errorCode = quitGroup(userId, groupId, true);
LOG.info("clear user {} group {} result {}", userId, groupId, errorCode); LOG.info("clear user {} group {} result {}", userId, groupId, errorCode);
} }
} }