commit | 3bf560cff2a7f30863ab507cc953f4b9f47d1bc7 | [log] [tgz] |
---|---|---|
author | Christian Schneider <cschneid@adobe.com> | Fri Sep 28 17:44:08 2018 +0200 |
committer | Christian Schneider <cschneid@adobe.com> | Fri Sep 28 17:44:08 2018 +0200 |
tree | ee5638c01704ad12d87841a0997dd109d793281f | |
parent | c1671baa4e2bb9a8ae1a644ab85f61d37ce8985d [diff] |
ARIES-1838 - Correctly register watcher for znode data changes
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 @@ 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; }