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); }