@ -45,10 +45,11 @@ public class GroupMessageStatusChangeProcessor implements ObjectProcessor<GroupM
|
||||
gmsg.setLastStatusChangeDate(LocalDateTime.now());
|
||||
|
||||
// Notifying the other members about the status change
|
||||
final var userID = connectionManager.getUserIDBySocketID(socketID);
|
||||
gmsg.getMemberMessageStatus()
|
||||
.keySet()
|
||||
.stream()
|
||||
.filter(k -> connectionManager.getUserIDBySocketID(socketID) != k)
|
||||
.filter(k -> userID != k)
|
||||
.filter(connectionManager::isOnline)
|
||||
.forEach(k -> writeProxy.write(connectionManager.getSocketID(k), statusChange));
|
||||
|
||||
|
Reference in New Issue
Block a user