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 0be55216..2a1466ba 100755 --- a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java +++ b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java @@ -212,7 +212,7 @@ public class MessagesPublisher { } if (pullType == ProtoConstants.PullType.Pull_ChatRoom) { - if (exceptClientId.equals(targetSession.getClientID())) { + if (exceptClientId != null && exceptClientId.equals(targetSession.getClientID())) { targetSession.refreshLastChatroomActiveTime(); }