diff options
author | 2018-10-10 00:12:04 +0300 | |
---|---|---|
committer | 2018-10-10 00:12:04 +0300 | |
commit | 26c7b4d910165f9a67cbfd6bfea97257ebf33a08 (patch) | |
tree | e49de848a762a31b8480cb176c683c030ad294d4 | |
parent | 3bbaae4589de56da9ab09360aa28a3cd12198471 (diff) |
Fix Websocket notifications for service users
-rw-r--r-- | juick-server/src/main/java/com/juick/server/ServerManager.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/juick-server/src/main/java/com/juick/server/ServerManager.java b/juick-server/src/main/java/com/juick/server/ServerManager.java index cbef33a5..e3bea1c0 100644 --- a/juick-server/src/main/java/com/juick/server/ServerManager.java +++ b/juick-server/src/main/java/com/juick/server/ServerManager.java @@ -107,7 +107,7 @@ public class ServerManager implements NotificationListener { synchronized (wsHandler.getClients()) { wsHandler.getClients().stream().filter(c -> (!c.legacy && c.visitor.isAnonymous()) // anonymous users - || c.visitor.getName().equals(serviceUser) // services + || c.visitor.equals(serviceUser) // services || (!c.legacy && uids.contains(c.visitor.getUid()))) // subscriptions .forEach(c -> { try { @@ -146,7 +146,7 @@ public class ServerManager implements NotificationListener { synchronized (wsHandler.getClients()) { wsHandler.getClients().stream().filter(c -> (!c.legacy && c.visitor.isAnonymous()) // anonymous users - || c.visitor.getName().equals(serviceUser) // services + || c.visitor.equals(serviceUser) // services || (!c.legacy && threadUsers.contains(c.visitor.getUid()))) // subscriptions .forEach(c -> { try { |