Fixed #1332

Atmosphere · Oct 8, 2013 · 0a21e3b · 0a21e3b
1 parent d67060a
commit 0a21e3b
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/modules/cpr/src/main/java/org/atmosphere/interceptor/AtmosphereResourceStateRecovery.java b/modules/cpr/src/main/java/org/atmosphere/interceptor/AtmosphereResourceStateRecovery.java
@@ -36,6 +36,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
@@ -197,11 +198,11 @@ public void onRemoveAtmosphereResource(Broadcaster b, AtmosphereResource r) {
 
     public final static class BroadcasterTracker {
 
-        private final List<String> broadcasterIds;
+        private final ConcurrentLinkedQueue<String> broadcasterIds;
         private long tick;
 
         public BroadcasterTracker() {
-            this.broadcasterIds = new LinkedList<String>();
+            this.broadcasterIds = new ConcurrentLinkedQueue<String>();
             tick = System.currentTimeMillis();
         }
 
@@ -219,7 +220,7 @@ public BroadcasterTracker remove(Broadcaster b) {
             return this;
         }
 
-        public List<String> ids() {
+        public ConcurrentLinkedQueue<String> ids() {
             return broadcasterIds;
         }