apache#1830: dbindex support in redis (apache#1831)

rolandhe · May 23, 2018 · 55461ab · 55461ab
1 parent 1efa9d4
commit 55461ab
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...ry/dubbo-registry-redis/src/main/java/com/alibaba/dubbo/registry/redis/RedisRegistry.java b/...ry/dubbo-registry-redis/src/main/java/com/alibaba/dubbo/registry/redis/RedisRegistry.java
@@ -134,10 +134,12 @@ public RedisRegistry(URL url) {
             }
             if (StringUtils.isEmpty(password)) {
                 this.jedisPools.put(address, new JedisPool(config, host, port,
-                        url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT)));
+                        url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT), null,
+                        url.getParameter("db.index", 0)));
             } else {
                 this.jedisPools.put(address, new JedisPool(config, host, port,
-                        url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT), password));
+                        url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT), password,
+                        url.getParameter("db.index", 0)));
             }
         }