diff --git a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java index 93b3618d..8715ac6f 100644 --- a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java +++ b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java @@ -994,7 +994,7 @@ public class DatabaseStore { } sb.append(")"); - sb.append(" and _scope = 6 and _key = ?"); + sb.append(" and _scope in (5,6,26) and _key = ?"); statement = connection.prepareStatement(sb.toString()); int index = 1;