diff --git a/commafeed-server/src/main/java/com/commafeed/frontend/ws/WebSocketSessions.java b/commafeed-server/src/main/java/com/commafeed/frontend/ws/WebSocketSessions.java index aadb1e57..f52e4673 100644 --- a/commafeed-server/src/main/java/com/commafeed/frontend/ws/WebSocketSessions.java +++ b/commafeed-server/src/main/java/com/commafeed/frontend/ws/WebSocketSessions.java @@ -34,10 +34,12 @@ public class WebSocketSessions { .flatMap(e -> e.getValue().stream()) .collect(Collectors.toSet()); - log.debug("sending '{}' to {} users via websocket", text, userSessions.size()); - for (Session userSession : userSessions) { - if (userSession.isOpen()) { - userSession.getAsyncRemote().sendText(text); + if (!userSessions.isEmpty()) { + log.debug("sending '{}' to {} users via websocket", text, userSessions.size()); + for (Session userSession : userSessions) { + if (userSession.isOpen()) { + userSession.getAsyncRemote().sendText(text); + } } } }