From 6ef8b78452e177bda25ad5da62d3ff8a2e01b7dd Mon Sep 17 00:00:00 2001 From: heavyrian2012 Date: Tue, 9 Jul 2024 16:06:10 +0800 Subject: [PATCH] =?UTF-8?q?server=20api=E8=8E=B7=E5=8F=96=E8=A2=AB?= =?UTF-8?q?=E5=B0=81=E7=A6=81=E7=94=A8=E6=88=B7=E6=97=B6=EF=BC=8C=E8=BF=87?= =?UTF-8?q?=E6=BB=A4=E6=8E=89=E6=AD=A3=E5=B8=B8=E7=94=A8=E6=88=B7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/io/moquette/persistence/MemoryMessagesStore.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 6f29e068..62cdbac4 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -2858,7 +2858,9 @@ public class MemoryMessagesStore implements IMessagesStore { IMap mUserMap = hzInstance.getMap(USER_STATUS); ArrayList out = new ArrayList<>(); for (Map.Entry 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; }