diff --git a/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java b/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java index 10b4d79f..74c0b37a 100755 --- a/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java @@ -282,7 +282,7 @@ public class MemorySessionStore implements ISessionsStore { while (it.hasNext()) { Session session = it.next().getValue(); if (!session.getClientID().equals(cid) && (session.pushType == pushType && token.equals(session.deviceToken))) { - session.deviceToken = token; + session.deviceToken = null; } } }