diff --git a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java index 6f8eff5e..0bfa756d 100644 --- a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java +++ b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java @@ -1153,7 +1153,7 @@ public class DatabaseStore { statement.setInt(index++, request.getPlatform()); } if (session.getPushType() != request.getPushType()) { - statement.setInt(index++, request.getPushType()); + statement.setInt(index++, request.getPushType() >= 32 ? 0 : request.getPushType()); } if (!strEqual(session.getDeviceName(), request.getDeviceName())) { statement.setString(index++, request.getDeviceName());