From bcf969e56ffc050c73b3465638a1428c84aeec4d Mon Sep 17 00:00:00 2001 From: heavyrain2012 Date: Thu, 21 Nov 2019 12:20:53 +0800 Subject: [PATCH] =?UTF-8?q?=E5=85=BC=E5=AE=B9=E6=97=A7=E5=AE=A2=E6=88=B7?= =?UTF-8?q?=E7=AB=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/io/moquette/persistence/MemoryMessagesStore.java | 3 +++ 1 file changed, 3 insertions(+) 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);