diff --git a/broker/src/main/java/com/xiaoleilu/loServer/action/admin/AddFriendRequestAction.java b/broker/src/main/java/com/xiaoleilu/loServer/action/admin/AddFriendRequestAction.java index 34e953e9..75ae39f8 100755 --- a/broker/src/main/java/com/xiaoleilu/loServer/action/admin/AddFriendRequestAction.java +++ b/broker/src/main/java/com/xiaoleilu/loServer/action/admin/AddFriendRequestAction.java @@ -47,7 +47,7 @@ public class AddFriendRequestAction extends AdminAction { byteBuf.writeBytes(result); ErrorCode errorCode = ErrorCode.fromCode(byteBuf.readByte()); return new Result(errorCode); - }, !input.isForce()); + }, input.isForce()); return false; } return true; diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 98c02c7c..e3935042 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -2639,7 +2639,7 @@ public class MemoryMessagesStore implements IMessagesStore { @Override public ErrorCode saveAddFriendRequest(String userId, WFCMessage.AddFriendRequest request, long[] head, boolean isAdmin) { - if (mDisableFriendRequest) { + if (!isAdmin && mDisableFriendRequest) { return ErrorCode.ERROR_CODE_NOT_RIGHT; }