diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index d4a8d56d..ae24e348 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -1896,7 +1896,10 @@ public class MemoryMessagesStore implements IMessagesStore { public ErrorCode blackUserRequest(String fromUser, String targetUserId, int state, long[] heads) { if (state == 2) { state = 1; + } else { + state = 0; } + HazelcastInstance hzInstance = m_Server.getHazelcastInstance(); MultiMap friendsMap = hzInstance.getMultiMap(USER_FRIENDS);