tripeur пре 4 година
родитељ
комит
5367585b15

+ 2 - 1
src/main/java/fr/jaquin/bdlg/planner/websockets/DisconnectListener.java

@@ -2,6 +2,7 @@ package fr.jaquin.bdlg.planner.websockets;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.ConcurrentHashMap;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.ApplicationListener;
 import org.springframework.messaging.simp.SimpMessagingTemplate;
@@ -20,7 +21,7 @@ public class DisconnectListener extends SubscriptionMap
   public void onApplicationEvent(SessionDisconnectEvent event) {
 
     String username = event.getUser().getName();
-    var map = getMap();
+    ConcurrentHashMap<String, List<String>> map = getMap();
     List<String> clearingList = new ArrayList<String>();
     map.forEach((uuid, list) -> {
       if (list.contains(username)) {

+ 3 - 1
src/main/java/fr/jaquin/bdlg/planner/websockets/SubscriptionListener.java

@@ -2,6 +2,8 @@ package fr.jaquin.bdlg.planner.websockets;
 
 import java.util.Collections;
 import java.util.LinkedList;
+import java.util.List;
+import java.util.concurrent.ConcurrentHashMap;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.ApplicationListener;
 import org.springframework.messaging.simp.SimpMessagingTemplate;
@@ -23,7 +25,7 @@ public class SubscriptionListener extends SubscriptionMap
     if (simpDestination.startsWith("/planning/")) {
       String uuid = simpDestination.substring(10);
       String username = event.getUser().getName();
-      var map = getMap();
+      ConcurrentHashMap<String, List<String>> map = getMap();
       if (!map.containsKey(uuid)) {
         map.put(uuid, Collections.synchronizedList(new LinkedList<String>()));
       } else {