From d366ddadfc272729cda4ffa91a27306cadc4cc2e Mon Sep 17 00:00:00 2001 From: Christian Date: Thu, 16 Jul 2015 22:23:57 +0200 Subject: [PATCH] Consider url parameter by RedisBroadcaster --- .../java/org/atmosphere/plugin/redis/RedisBroadcaster.java | 3 +-- 1 file changed, 1 insertion(+), 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 index 4cf6a2493..786399814 100644 --- 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