Merge pull request #3 from wangchangbing/master

admin项目订阅zk时当interface包含内部类$字符时出现问题
apache · Feb 28, 2013 · a4140d2 · a4140d2
2 parents 935fe30 + 9552833
commit a4140d2
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...istry-zookeeper/src/main/java/com/alibaba/dubbo/registry/zookeeper/ZookeeperRegistry.java b/...istry-zookeeper/src/main/java/com/alibaba/dubbo/registry/zookeeper/ZookeeperRegistry.java
@@ -125,6 +125,7 @@ protected void doSubscribe(final URL url, final NotifyListener listener) {
                     listeners.putIfAbsent(listener, new ChildListener() {
                         public void childChanged(String parentPath, List<String> currentChilds) {
                             for (String child : currentChilds) {
+								child = URL.decode(child);
                                 if (! anyServices.contains(child)) {
                                     anyServices.add(child);
                                     subscribe(url.setPath(child).addParameters(Constants.INTERFACE_KEY, child, 
@@ -138,8 +139,9 @@ public void childChanged(String parentPath, List<String> currentChilds) {
                 zkClient.create(root, false);
                 List<String> services = zkClient.addChildListener(root, zkListener);
                 if (services != null && services.size() > 0) {
-                    anyServices.addAll(services);
                     for (String service : services) {
+						service = URL.decode(service);
+						anyServices.add(service);
                         subscribe(url.setPath(service).addParameters(Constants.INTERFACE_KEY, service, 
                                 Constants.CHECK_KEY, String.valueOf(false)), listener);
                     }