From f2f75d3048314a5d4b42135b3650c9e6465bb231 Mon Sep 17 00:00:00 2001 From: imhao183 Date: Fri, 12 Jun 2020 07:54:28 +0800 Subject: [PATCH] =?UTF-8?q?=E8=AE=A1=E6=95=B0=E9=97=AE=E9=A2=98=E4=BF=AE?= =?UTF-8?q?=E6=AD=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/io/moquette/spi/impl/MessagesPublisher.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java index 9316c30e..9ad876e4 100755 --- a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java +++ b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java @@ -253,7 +253,7 @@ public class MessagesPublisher { } } - if (!StringUtil.isNullOrEmpty(pushContent) || messageContentType == 400 || messageContentType == 402) { + if (!StringUtil.isNullOrEmpty(pushContent) || messageContentType == 400) { if (!isSlient) { targetSession.setUnReceivedMsgs(targetSession.getUnReceivedMsgs() + 1); }