diff options
author | Vitaly Takmazov | 2018-10-09 14:29:47 +0300 |
---|---|---|
committer | Vitaly Takmazov | 2018-10-09 14:29:47 +0300 |
commit | 3bbaae4589de56da9ab09360aa28a3cd12198471 (patch) | |
tree | 436fd6436e582d0de7cbb0b3373e3d2d9fcc97ee /juick-notifications/src/main/java/com/juick/components/NotificationsManager.java | |
parent | 9eb0139ed6a0e823a0863c8734278e620587627f (diff) |
MessageReadEvent refactoring
Diffstat (limited to 'juick-notifications/src/main/java/com/juick/components/NotificationsManager.java')
-rw-r--r-- | juick-notifications/src/main/java/com/juick/components/NotificationsManager.java | 4 |
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) { |