修改pc等平台pushtype越界问题

wildfirechat · Sep 7, 2019 · 83b6ae5 · 83b6ae5
1 parent 4b7804c
commit 83b6ae5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java
@@ -1153,7 +1153,7 @@ void updateSession(String uid, String cid, MemorySessionStore.Session session, W
                     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());