diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 4f83bbe0..a5792c25 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -3210,7 +3210,7 @@ public class MemoryMessagesStore implements IMessagesStore { friendsMap.remove(userId); friendsMap.remove(request.getTargetUid()); - callbackRelationEvent(userId, request.getTargetUid(), 0, "" + request.getStatus()); + callbackRelationEvent(userId, request.getTargetUid(), 0, request.getStatus() == 0?"1":"0"); return ErrorCode.ERROR_CODE_SUCCESS; }