#1830: dbindex support in redis (#1831)

beiwei30 · web-flow · commit 300f9c9fe1e4 · 2018-05-23T10:10:46.000+08:00
diff --git a/dubbo-registry/dubbo-registry-redis/src/main/java/com/alibaba/dubbo/registry/redis/RedisRegistry.java b/dubbo-registry/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)));
             }
         }
 

Original file line number	Diff line number	Diff line change
`@@ -134,10 +134,12 @@ public RedisRegistry(URL url) {`
`134`	`134`	`}`
`135`	`135`	`if (StringUtils.isEmpty(password)) {`
`136`	`136`	`this.jedisPools.put(address, new JedisPool(config, host, port,`
`137`		`- url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT)));`
	`137`	`+ url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT), null,`
	`138`	`+ url.getParameter("db.index", 0)));`
`138`	`139`	`} else {`
`139`	`140`	`this.jedisPools.put(address, new JedisPool(config, host, port,`
`140`		`- url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT), password));`
	`141`	`+ url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT), password,`
	`142`	`+ url.getParameter("db.index", 0)));`
`141`	`143`	`}`
`142`	`144`	`}`
`143`	`145`