diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 37446328..bf45269c 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -640,6 +640,17 @@ public class MemoryMessagesStore implements IMessagesStore { } } + if(fromMessageId == 1) { //lite mode + if(maps == null || maps.isEmpty()) { + head = 0; + } else { + head = maps.lastKey(); + } + builder.setCurrent(head); + builder.setHead(head); + return builder.build(); + } + mReadLock.lock(); int size = 0; try {