From 00f11872007deaaefe2122963917463abfa6e2f8 Mon Sep 17 00:00:00 2001 From: imhao183 Date: Thu, 5 Dec 2019 15:41:56 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E7=BE=A4=E4=B8=BB=E8=BF=9B?= =?UTF-8?q?=E7=BE=A4=E6=97=B6=EF=BC=8C=E4=BF=AE=E6=94=B9=E7=BE=A4=E4=B8=BB?= =?UTF-8?q?=E7=9A=84=E7=9A=84=E7=8A=B6=E6=80=81=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/io/moquette/persistence/MemoryMessagesStore.java | 6 +++++- 1 file changed, 5 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 66c0c021..60d9e368 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -687,7 +687,11 @@ public class MemoryMessagesStore implements IMessagesStore { List tmp = new ArrayList<>(); ArrayList newInviteUsers = new ArrayList<>(); for (WFCMessage.GroupMember member : memberList) { - member = member.toBuilder().setType(ProtoConstants.GroupMemberType.GroupMemberType_Normal).setUpdateDt(updateDt).setAlias("").build(); + if (member.getMemberId().equals(groupInfo.getOwner())) { + member = member.toBuilder().setType(GroupMemberType_Owner).setUpdateDt(updateDt).setAlias("").build(); + } else { + member = member.toBuilder().setType(GroupMemberType_Normal).setUpdateDt(updateDt).setAlias("").build(); + } tmp.add(member); newInviteUsers.add(member.getMemberId()); }