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

server api获取被封禁用户时，过滤掉正常用户

Browse Source
This commit is contained in:
heavyrian2012
2024-07-09 16:06:10 +08:00
parent 100a1bd44c
commit 6ef8b78452
1 changed files with 3 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
+3 -1
View File
@@ -2858,7 +2858,9 @@ public class MemoryMessagesStore implements IMessagesStore {
IMap<String, Integer> mUserMap = hzInstance.getMap(USER_STATUS); IMap<String, Integer> mUserMap = hzInstance.getMap(USER_STATUS);
ArrayList<InputOutputUserBlockStatus> out = new ArrayList<>(); ArrayList<InputOutputUserBlockStatus> out = new ArrayList<>();
for (Map.Entry<String, Integer> entry : mUserMap.entrySet()) { for (Map.Entry<String, Integer> entry : mUserMap.entrySet()) {
out.add(new InputOutputUserBlockStatus(entry.getKey(), entry.getValue())); if(entry.getValue() > 0) {
out.add(new InputOutputUserBlockStatus(entry.getKey(), entry.getValue()));
}
} }
return out; return out;
} }