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) {

Reply via email to