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; }