MessageReadEvent refactoring

1 files changed, 3 insertions, 1 deletions

diff --git a/juick-notifications/src/main/java/com/juick/components/NotificationsManager.java b/juick-notifications/src/main/java/com/juick/components/NotificationsManager.java
index be97ea40..fce0bed7 100644
--- a/juick-notifications/src/main/java/com/juick/components/NotificationsManager.java
+++ b/juick-notifications/src/main/java/com/juick/components/NotificationsManager.java
@@ -103,7 +103,9 @@ public class NotificationsManager extends TextWebSocketHandler {
                 jmsg.getUser().getUid()),
                 HttpMethod.GET, null, new ParameterizedTypeReference<List<User>>() {
                 }).getBody();
-        applicationEventPublisher.publishEvent(new MessageReadEvent(this, users, jmsg));
+        users.forEach(user -> {
+            applicationEventPublisher.publishEvent(new MessageReadEvent(this, user, jmsg));
+        });
     }
 
     public void addInvalidGCMToken(String token) {