diff --git a/src/main/java/envoy/server/processors/GroupMessageStatusChangeProcessor.java b/src/main/java/envoy/server/processors/GroupMessageStatusChangeProcessor.java index cc86e0c..fa3bcb2 100644 --- a/src/main/java/envoy/server/processors/GroupMessageStatusChangeProcessor.java +++ b/src/main/java/envoy/server/processors/GroupMessageStatusChangeProcessor.java @@ -45,10 +45,11 @@ public class GroupMessageStatusChangeProcessor implements ObjectProcessor connectionManager.getUserIDBySocketID(socketID) != k) + .filter(k -> userID != k) .filter(connectionManager::isOnline) .forEach(k -> writeProxy.write(connectionManager.getSocketID(k), statusChange));