No need to delete watcher. WatcherRemoveCuratorFramework does it automatically
Project: http://git-wip-us.apache.org/repos/asf/curator/repo Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/ea643a2f Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/ea643a2f Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/ea643a2f Branch: refs/heads/CURATOR-3.0 Commit: ea643a2fda23065477e7cdf21c996239cc60d213 Parents: 3db1081 Author: randgalt <[email protected]> Authored: Fri Feb 5 12:21:06 2016 -0500 Committer: randgalt <[email protected]> Committed: Fri Feb 5 12:21:06 2016 -0500 ---------------------------------------------------------------------- .../java/org/apache/curator/framework/recipes/cache/TreeCache.java | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/curator/blob/ea643a2f/curator-recipes/src/main/java/org/apache/curator/framework/recipes/cache/TreeCache.java ---------------------------------------------------------------------- diff --git a/curator-recipes/src/main/java/org/apache/curator/framework/recipes/cache/TreeCache.java b/curator-recipes/src/main/java/org/apache/curator/framework/recipes/cache/TreeCache.java index df4403c..69c9c6f 100644 --- a/curator-recipes/src/main/java/org/apache/curator/framework/recipes/cache/TreeCache.java +++ b/curator-recipes/src/main/java/org/apache/curator/framework/recipes/cache/TreeCache.java @@ -303,7 +303,6 @@ public class TreeCache implements Closeable void wasDeleted() throws Exception { ChildData oldChildData = childData.getAndSet(null); - client.watches().remove(this).ofType(WatcherType.Any).locally().inBackground().forPath(path); ConcurrentMap<String, TreeNode> childMap = children.getAndSet(null); if ( childMap != null ) {
