This is an automated email from the ASF dual-hosted git repository. liujun pushed a commit to branch dev-metadata in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git
commit 507f5bfc2967442a5b40b2f535c9f17cd5519ef0 Author: ken.lj <ken.lj...@gmail.com> AuthorDate: Sun Sep 9 17:08:04 2018 +0800 Update config connecting status when ZK connection changes. --- .../dynamic/support/archaius/sources/ZooKeeperConfigurationSource.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/dubbo-config/dubbo-config-dynamic/src/main/java/org/apache/dubbo/config/dynamic/support/archaius/sources/ZooKeeperConfigurationSource.java b/dubbo-config/dubbo-config-dynamic/src/main/java/org/apache/dubbo/config/dynamic/support/archaius/sources/ZooKeeperConfigurationSource.java index 6e91624..41d6861 100644 --- a/dubbo-config/dubbo-config-dynamic/src/main/java/org/apache/dubbo/config/dynamic/support/archaius/sources/ZooKeeperConfigurationSource.java +++ b/dubbo-config/dubbo-config-dynamic/src/main/java/org/apache/dubbo/config/dynamic/support/archaius/sources/ZooKeeperConfigurationSource.java @@ -117,6 +117,9 @@ public class ZooKeeperConfigurationSource implements WatchedConfigurationSource, TreeCacheEvent.Type type = event.getType(); ChildData data = event.getData(); + if (type == TreeCacheEvent.Type.INITIALIZED || type == TreeCacheEvent.Type.CONNECTION_RECONNECTED) { + connected = true; + } // TODO, ignore other event types if (data == null) {