You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@curator.apache.org by ra...@apache.org on 2017/05/02 03:56:51 UTC
[07/20] curator git commit: check for all events on test node
check for all events on test node
Project: http://git-wip-us.apache.org/repos/asf/curator/repo
Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/be4960a5
Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/be4960a5
Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/be4960a5
Branch: refs/heads/CURATOR-397
Commit: be4960a522ca91519671708a3a59530fd1a16850
Parents: 7aa5617
Author: randgalt <ra...@apache.org>
Authored: Fri Dec 9 15:37:47 2016 +0100
Committer: randgalt <ra...@apache.org>
Committed: Fri Dec 9 15:37:47 2016 +0100
----------------------------------------------------------------------
.../framework/recipes/nodes/TestPersistentTtlNode.java | 7 ++-----
1 file changed, 2 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/curator/blob/be4960a5/curator-recipes/src/test/java/org/apache/curator/framework/recipes/nodes/TestPersistentTtlNode.java
----------------------------------------------------------------------
diff --git a/curator-recipes/src/test/java/org/apache/curator/framework/recipes/nodes/TestPersistentTtlNode.java b/curator-recipes/src/test/java/org/apache/curator/framework/recipes/nodes/TestPersistentTtlNode.java
index 848c034..be38f6e 100644
--- a/curator-recipes/src/test/java/org/apache/curator/framework/recipes/nodes/TestPersistentTtlNode.java
+++ b/curator-recipes/src/test/java/org/apache/curator/framework/recipes/nodes/TestPersistentTtlNode.java
@@ -79,12 +79,9 @@ public class TestPersistentTtlNode extends BaseClassForTests
@Override
public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws Exception
{
- if ( event.getType() == PathChildrenCacheEvent.Type.CHILD_UPDATED )
+ if ( (event.getData() != null) && "/test".equals(event.getData().getPath()) )
{
- if ( event.getData().getPath().equals("/test") )
- {
- changes.release();
- }
+ changes.release();
}
}
};