natas_hw
/
dubbo
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

DUBBO-234 redis注册中心健状性处理 

git-svn-id: http://code.alibabatech.com/svn/dubbo/trunk@1221 1a56cb94-b969-4eaa-88fa-be21384802f2
This commit is contained in:
william.liangf 2012-03-08 21:55:17 +00:00
parent 4c9276b60f
commit 0e017b4405
2 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dubbo-common/src/main/java/com/alibaba/dubbo/common/URL.java
View File

@ -1059,6 +1059,10 @@ public final class URL implements Serializable {
return getParameter(Constants.INTERFACE_KEY, path);
}
public URL setServiceInterface(String service) {
return addParameter(Constants.INTERFACE_KEY, service);
}
public int hashCode() {
final int prime = 31;
int result = 1;

7
dubbo-registry-redis/src/main/java/com/alibaba/dubbo/registry/redis/RedisRegistry.java
View File

@ -331,6 +331,13 @@ public class RedisRegistry extends FailbackRegistry {
}
}
}
if (urls != null && urls.isEmpty() && url.getParameter(Constants.ADMIN_KEY, false)) {
URL empty = url.setProtocol(Constants.EMPTY_PROTOCOL);
if (Constants.ANY_VALUE.equals(empty.getServiceInterface())) {
empty = empty.setServiceInterface(service.substring(root.length()));
}
urls.add(empty);
}
for (NotifyListener listener : listeners) {
notify(url, listener, urls);
}