diff --git a/backend/src/main/java/ch/akop/homesystem/controller/for_private/websocket/AbstractBaseSocket.java b/backend/src/main/java/ch/akop/homesystem/controller/for_private/websocket/AbstractBaseSocket.java index 06156e9..282d443 100644 --- a/backend/src/main/java/ch/akop/homesystem/controller/for_private/websocket/AbstractBaseSocket.java +++ b/backend/src/main/java/ch/akop/homesystem/controller/for_private/websocket/AbstractBaseSocket.java @@ -32,7 +32,8 @@ public void broadcast(Object message) { @SneakyThrows public void sendMessage(Session session, Object message) { - if (sendHashCodes.getOrDefault(session, new HashSet<>()).contains(message.hashCode())) { + sendHashCodes.putIfAbsent(session, new HashSet<>()); + if (sendHashCodes.get(session).contains(message.hashCode())) { return; } sendHashCodes.getOrDefault(session, new HashSet<>()).add(message.hashCode());