| @@ -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
	 DieGurke
					DieGurke