You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by li...@apache.org on 2018/09/09 09:08:34 UTC
[incubator-dubbo] 02/02: Update config connecting status when ZK
connection changes.
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 <ke...@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) {