From dabb92571a8f08a8c1c791d6d8b2fbc2edc7d2ac Mon Sep 17 00:00:00 2001
From: heavyrian2012 <heavyrain.lee@wildfirehat.cn>
Date: Wed, 9 Feb 2022 22:58:48 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E5=90=91=E6=B6=88=E6=81=AF=EF=BC=8C?=
 =?UTF-8?q?=E5=A6=82=E6=9E=9C=E7=9B=AE=E6=A0=87=E7=94=A8=E6=88=B7=E5=A4=9A?=
 =?UTF-8?q?=E4=BA=8E1=E4=BA=BA=EF=BC=8C=E5=8F=96=E7=AC=AC=E4=B8=80?=
 =?UTF-8?q?=E4=B8=AA=E4=BF=9D=E5=AD=98=E5=88=B0=E6=95=B0=E6=8D=AE=E5=BA=93?=
 =?UTF-8?q?=E4=B8=AD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 broker/src/main/java/io/moquette/persistence/DatabaseStore.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java
index e852d8f1..636dbf98 100644
--- a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java
+++ b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java
@@ -553,7 +553,7 @@ public class DatabaseStore {
                 statement.setInt(index++, message.getContent().getType());
                 String to = message.getToUser();
                 if (StringUtil.isNullOrEmpty(message.getToUser())) {
-                    if (message.getToList()!= null && message.getToList().size() == 1) {
+                    if (message.getToList().size() > 0) {
                         to = message.getToList().get(0);
                     }
                 }