fix

AndreKoepke · Feb 20, 2025 · c2ef8a6 · c2ef8a6
1 parent 038a634
commit c2ef8a6
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...src/main/java/ch/akop/homesystem/controller/for_private/websocket/AbstractBaseSocket.java b/...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());