Improve fix for #1342

Atmosphere · Oct 15, 2013 · a48062d · a48062d
1 parent 0fccd00
commit a48062d
Showing 1 changed file with 1 addition 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
@@ -198,9 +198,7 @@ public void onRemoveAtmosphereResource(Broadcaster b, AtmosphereResource r) {
                 t.remove(b);
             } else {
                 // The BroadcasterTracker was swapped
-                if (t == null) {
-                    onAddAtmosphereResource(b, r);
-                }
+                onAddAtmosphereResource(b, r);
                 logger.trace("Keeping the state of {} with broadcaster {}", r.uuid(), b.getID());
                 logger.trace("State for {} with broadcaster {}", r.uuid(), t != null ? t.ids() : "null");
             }