diff --git a/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java b/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java index 0f07a4f9..664babbc 100755 --- a/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java @@ -145,6 +145,9 @@ public class MemorySessionStore implements ISessionsStore { public void setUpdateDt(long updateDt) { this.updateDt = updateDt; + if (this.lastActiveTime == 0) { + this.lastActiveTime = updateDt; + } } private int pushType;