From ecd87534ce87ee34d16112a05047858431e4cc74 Mon Sep 17 00:00:00 2001
From: jfarcand <jfarcand@apache.org>
Date: Tue, 8 Oct 2013 10:36:33 -0400
Subject: [PATCH] Fixed #1332

---
 .../interceptor/AtmosphereResourceStateRecovery.java       | 7 ++++---
 1 file changed, 4 insertions(+), 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
index 23ff78b8ec7..87bae8b8eec 100644
--- 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;
         }