diff options
| -rw-r--r-- | juick-server/src/main/java/com/juick/server/ServerManager.java | 5 | ||||
| -rw-r--r-- | juick-www/src/test/java/com/juick/WebAppTests.java | 1 |
2 files changed, 6 insertions, 0 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 b6e3afcf..92821feb 100644 --- a/juick-server/src/main/java/com/juick/server/ServerManager.java +++ b/juick-server/src/main/java/com/juick/server/ServerManager.java @@ -202,6 +202,11 @@ public class ServerManager implements NotificationListener { serviceMessage.setUser(userTo); serviceMessage.setMid(source.getMid()); serviceMessage.setUnread(false); + try { + u.session.sendMessage(new TextMessage(jsonMapper.writeValueAsString(serviceMessage))); + } catch (IOException e) { + logger.error("JSON error", e); + } }); } } diff --git a/juick-www/src/test/java/com/juick/WebAppTests.java b/juick-www/src/test/java/com/juick/WebAppTests.java index b625f7eb..4f6a5057 100644 --- a/juick-www/src/test/java/com/juick/WebAppTests.java +++ b/juick-www/src/test/java/com/juick/WebAppTests.java @@ -428,6 +428,7 @@ public class WebAppTests { unreadThread.refresh(); assertThat(listener.getUnreadCounts().size(), is(2)); assertThat(listener.getUnreadCounts().get(1), is(0)); + assertThat(freefd.isAnonymous(), is(false)); } public static class EventListenerConfig { |