From 40ef9abd35b52239f8103112edde7832f86fb19e Mon Sep 17 00:00:00 2001 From: heavyrain2012 Date: Sat, 8 Jan 2022 16:36:18 +0800 Subject: [PATCH] =?UTF-8?q?=E9=94=80=E6=AF=81=E7=94=A8=E6=88=B7=E6=97=B6?= =?UTF-8?q?=EF=BC=8C=E6=B8=85=E7=90=86=E5=B9=B2=E5=87=80=E6=89=80=E6=9C=89?= =?UTF-8?q?=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../persistence/MemoryMessagesStore.java | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 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 48c06b18..fb4bccb5 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -2488,7 +2488,21 @@ 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).setDeleted(1).build(); + us = WFCMessage.User.newBuilder() + .setUid(userId) + .setUpdateDt(System.currentTimeMillis()) + .setName(userId) + .setDeleted(1) + .clearDisplayName() + .clearAddress() + .clearCompany() + .clearEmail() + .clearExtra() + .clearMobile() + .clearPortrait() + .clearSocial() + .build(); + try { databaseStore.updateUser(us); } catch (Exception e) {