From 1aed4b1d37a7f25a3c1568611d9b6e439a49ed14 Mon Sep 17 00:00:00 2001 From: heavyrian2012 Date: Wed, 29 May 2024 16:08:37 +0800 Subject: [PATCH] =?UTF-8?q?=E6=90=9C=E7=B4=A2=E9=A2=91=E9=81=93=E6=97=B6?= =?UTF-8?q?=EF=BC=8C=E8=A7=A3=E5=86=B3=E6=9F=90=E4=BA=9B=E9=A2=91=E9=81=93?= =?UTF-8?q?=E4=B8=8D=E8=83=BD=E6=90=9C=E7=B4=A2=E5=87=BA=E6=9D=A5=E7=9A=84?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/io/moquette/persistence/DatabaseStore.java | 6 +++++- 1 file changed, 5 insertions(+), 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 63bc6687..64c45019 100644 --- a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java +++ b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java @@ -3767,7 +3767,11 @@ public class DatabaseStore { sql += " where `_name` = ?"; } - sql += " and _status = 0"; + sql += " and _status <> 64"; + sql += " and _status <> 16"; + sql += " and _status <> 17"; + sql += " and _status <> 24"; + sql += " and _status <> 25"; sql += " limit 20";