diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
index 3a7164b1..0edcf851 100755
--- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
@@ -2318,6 +2318,8 @@ public class MemoryMessagesStore implements IMessagesStore {
 
         if (state == 2) {
             state = 1;
+        } else {
+            state = 0;
         }
 
         HazelcastInstance hzInstance = m_Server.getHazelcastInstance();