From 1f5f7eb572becb642b776ee1d52ade66bf9e2ba1 Mon Sep 17 00:00:00 2001 From: imhao183 Date: Sat, 1 Aug 2020 09:25:24 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=E6=8E=A8=E9=80=81=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E4=B8=ADunread=20message=20count=E4=B8=8D=E5=87=86?= =?UTF-8?q?=E7=A1=AE=E7=9A=84=E9=97=AE=E9=A2=98?= 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 7273ea2c..715a213b 100755 --- a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java +++ b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java @@ -254,7 +254,7 @@ public class MessagesPublisher { } if (!StringUtil.isNullOrEmpty(pushContent) || messageContentType == 400) { - if (!isSlient) { + if (!isSlient && (persistFlag & 0x02) > 0) { targetSession.setUnReceivedMsgs(targetSession.getUnReceivedMsgs() + 1); } }