You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@aries.apache.org by cs...@apache.org on 2018/09/28 15:46:45 UTC
[aries-rsa] 02/03: ARIES-1838 - Correctly register watcher for
znode data changes
This is an automated email from the ASF dual-hosted git repository.
cschneider pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/aries-rsa.git
commit 3bf560cff2a7f30863ab507cc953f4b9f47d1bc7
Author: Christian Schneider <cs...@adobe.com>
AuthorDate: Fri Sep 28 17:44:08 2018 +0200
ARIES-1838 - Correctly register watcher for znode data changes
---
.../rsa/discovery/zookeeper/repository/ZookeeperEndpointRepository.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/discovery/zookeeper/src/main/java/org/apache/aries/rsa/discovery/zookeeper/repository/ZookeeperEndpointRepository.java b/discovery/zookeeper/src/main/java/org/apache/aries/rsa/discovery/zookeeper/repository/ZookeeperEndpointRepository.java
index 89003a6..9eec4a7 100644
--- a/discovery/zookeeper/src/main/java/org/apache/aries/rsa/discovery/zookeeper/repository/ZookeeperEndpointRepository.java
+++ b/discovery/zookeeper/src/main/java/org/apache/aries/rsa/discovery/zookeeper/repository/ZookeeperEndpointRepository.java
@@ -234,7 +234,7 @@ public class ZookeeperEndpointRepository implements Closeable, Watcher {
private void handleZNodeChanged(String path) throws KeeperException, InterruptedException {
Stat stat = new Stat();
- byte[] data = zk.getData(path, false, stat);
+ byte[] data = zk.getData(path, this, stat);
if (data == null || data.length == 0) {
return;
}