diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 59745ccf..0781dec2 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -2205,7 +2205,8 @@ public class MemoryMessagesStore implements IMessagesStore { public ErrorCode handleFriendRequest(String userId, WFCMessage.HandleFriendRequest request, WFCMessage.Message.Builder msgBuilder, long[] heads, boolean isAdmin) { HazelcastInstance hzInstance = m_Server.getHazelcastInstance(); - if(request.getStatus() == ProtoConstants.FriendRequestStatus.RequestStatus_Accepted) { + + if(!isAdmin && request.getStatus() == ProtoConstants.FriendRequestStatus.RequestStatus_Accepted) { MultiMap friendsMap = hzInstance.getMultiMap(USER_FRIENDS); Collection friends = friendsMap.get(userId);