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";