Fix for #720

Atmosphere · Nov 6, 2012 · da77254 · da77254
1 parent a355f05
commit da77254
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/modules/cpr/src/main/java/org/atmosphere/util/SimpleBroadcaster.java b/modules/cpr/src/main/java/org/atmosphere/util/SimpleBroadcaster.java
@@ -82,12 +82,7 @@ public SimpleBroadcaster(String id, AtmosphereConfig config) {
      */
     @Override
     protected BroadcasterConfig createBroadcasterConfig(AtmosphereConfig config){
-        BroadcasterConfig bc = (BroadcasterConfig) config.properties().get(BroadcasterConfig.class.getName());
-        if (bc == null) {
-            bc = new BroadcasterConfig(config.framework().broadcasterFilters(), config, false);
-            config.properties().put(BroadcasterConfig.class.getName(), bc);
-        }
-        return bc;
+        return new BroadcasterConfig(config.framework().broadcasterFilters(), config, false);
     }
 
     protected void start() {