From 35db76e9cda6756bda35c2f9c64ba40aca4a98df Mon Sep 17 00:00:00 2001 From: fengyun Date: Sat, 30 Nov 2019 11:54:36 +0800 Subject: [PATCH] set use deleted --- .../main/java/io/moquette/persistence/MemoryMessagesStore.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index a2b4ab65..1036c84d 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -1459,7 +1459,7 @@ public class MemoryMessagesStore implements IMessagesStore { IMap mUserMap = hzInstance.getMap(USERS); WFCMessage.User us = mUserMap.get(userId); if (us != null) { - us = WFCMessage.User.newBuilder().setUid(userId).setUpdateDt(System.currentTimeMillis()).setDisplayName("已删除用户").setName(userId).build(); + us = WFCMessage.User.newBuilder().setUid(userId).setUpdateDt(System.currentTimeMillis()).setDisplayName("已删除用户").setName(userId).setDeleted(1).build(); mUserMap.put(userId, us); }