From d66b01c681bf1280d8c5f0c7af6c40380f63117b Mon Sep 17 00:00:00 2001
From: "heavyrain.lee" <heavyrain.lee@gmail.com>
Date: Tue, 21 May 2019 21:35:34 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E9=83=A8=E5=88=86=E9=94=99?=
 =?UTF-8?q?=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../xiaoleilu/loServer/pojos/InputCreateGroup.java   | 12 ++++++++----
 .../io/moquette/persistence/MemoryMessagesStore.java |  2 ++
 2 files changed, 10 insertions(+), 4 deletions(-)

diff --git a/broker/src/main/java/com/xiaoleilu/loServer/pojos/InputCreateGroup.java b/broker/src/main/java/com/xiaoleilu/loServer/pojos/InputCreateGroup.java
index ebb49cc4..92bdff99 100755
--- a/broker/src/main/java/com/xiaoleilu/loServer/pojos/InputCreateGroup.java
+++ b/broker/src/main/java/com/xiaoleilu/loServer/pojos/InputCreateGroup.java
@@ -58,12 +58,16 @@ public class InputCreateGroup extends InputGroupBase {
 
         WFCMessage.CreateGroupRequest.Builder createGroupReqBuilder = WFCMessage.CreateGroupRequest.newBuilder();
         createGroupReqBuilder.setGroup(groupBuilder);
-        for (Integer line : to_lines
-             ) {
-            createGroupReqBuilder.addToLine(line);
+        if (to_lines != null) {
+            for (Integer line : to_lines
+            ) {
+                createGroupReqBuilder.addToLine(line);
+            }
         }
 
-        createGroupReqBuilder.setNotifyContent(notify_message.toProtoMessageContent());
+        if (notify_message != null) {
+            createGroupReqBuilder.setNotifyContent(notify_message.toProtoMessageContent());
+        }
         return createGroupReqBuilder.build();
     }
 
diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
index d2221124..aae763c7 100755
--- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
@@ -583,6 +583,8 @@ public class MemoryMessagesStore implements IMessagesStore {
         long dt = System.currentTimeMillis();
         if (StringUtil.isNullOrEmpty(groupInfo.getTargetId())) {
             groupId = getShortUUID();
+        } else {
+            groupId = groupInfo.getTargetId();
         }
         groupInfo = groupInfo.toBuilder()
             .setTargetId(groupId)