diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index f8f82ad6..d27086a5 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -2819,6 +2819,10 @@ public class MemoryMessagesStore implements IMessagesStore { return ErrorCode.ERROR_CODE_IN_BLACK_LIST; } + if (friendData1 != null && friendData1.getState() == 0) { + return ErrorCode.ERROR_CODE_ALREADY_FRIENDS; + } + WFCMessage.FriendRequest newRequest = WFCMessage.FriendRequest .newBuilder() .setFromUid(userId)