From 83b6ae5229fa533b7942f37b1235e4f859333a67 Mon Sep 17 00:00:00 2001
From: "heavyrain.lee" <heavyrain.lee@gmail.com>
Date: Sat, 7 Sep 2019 14:50:34 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9pc=E7=AD=89=E5=B9=B3=E5=8F=B0?=
 =?UTF-8?q?pushtype=E8=B6=8A=E7=95=8C=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 broker/src/main/java/io/moquette/persistence/DatabaseStore.java | 2 +-
 1 file changed, 1 insertion(+), 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 6f8eff5eb..0bfa756db 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 @@ 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());