Consider url parameter by RedisBroadcaster

Atmosphere · Jul 16, 2015 · d366dda · d366dda
1 parent e12fe77
commit d366dda
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/redis/modules/src/main/java/org/atmosphere/plugin/redis/RedisBroadcaster.java b/redis/modules/src/main/java/org/atmosphere/plugin/redis/RedisBroadcaster.java
@@ -18,6 +18,7 @@
 
 import org.atmosphere.cpr.AtmosphereConfig;
 import org.atmosphere.cpr.Broadcaster;
+import org.atmosphere.plugin.redis.RedisUtil;
 import org.atmosphere.util.AbstractBroadcasterProxy;
 
 import java.net.URI;
@@ -38,8 +39,6 @@ public Broadcaster initialize(String id, AtmosphereConfig config) {
     }
 
     public Broadcaster initialize(String id, URI uri, AtmosphereConfig config) {
-        // Ignore default.
-        uri = URI.create("http://localhost:6379");
         super.initialize(id, uri, config);
         this.redisUtil = new RedisUtil(uri, config, new RedisUtil.Callback() {
             @Override