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;
         }