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 2016/01/15 18:47:40 UTC
curator git commit: updated tests for new values in NODE_REMOVED
Repository: curator
Updated Branches:
refs/heads/CURATOR-288 6b8113b65 -> 0a3240f05
updated tests for new values in NODE_REMOVED
Project: http://git-wip-us.apache.org/repos/asf/curator/repo
Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/0a3240f0
Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/0a3240f0
Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/0a3240f0
Branch: refs/heads/CURATOR-288
Commit: 0a3240f05bff69a87dd6a743d3afac61f8954494
Parents: 6b8113b
Author: randgalt <ra...@apache.org>
Authored: Fri Jan 15 12:47:33 2016 -0500
Committer: randgalt <ra...@apache.org>
Committed: Fri Jan 15 12:47:33 2016 -0500
----------------------------------------------------------------------
.../curator/framework/recipes/cache/TestTreeCache.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/curator/blob/0a3240f0/curator-recipes/src/test/java/org/apache/curator/framework/recipes/cache/TestTreeCache.java
----------------------------------------------------------------------
diff --git a/curator-recipes/src/test/java/org/apache/curator/framework/recipes/cache/TestTreeCache.java b/curator-recipes/src/test/java/org/apache/curator/framework/recipes/cache/TestTreeCache.java
index 767b3ae..b5b9c9f 100644
--- a/curator-recipes/src/test/java/org/apache/curator/framework/recipes/cache/TestTreeCache.java
+++ b/curator-recipes/src/test/java/org/apache/curator/framework/recipes/cache/TestTreeCache.java
@@ -373,12 +373,12 @@ public class TestTreeCache extends BaseTestTreeCache
assertEvent(TreeCacheEvent.Type.INITIALIZED);
client.delete().forPath("/test/foo");
- assertEvent(TreeCacheEvent.Type.NODE_REMOVED, "/test/foo");
+ assertEvent(TreeCacheEvent.Type.NODE_REMOVED, "/test/foo", "one".getBytes());
client.create().forPath("/test/foo", "two".getBytes());
assertEvent(TreeCacheEvent.Type.NODE_ADDED, "/test/foo");
client.delete().forPath("/test/foo");
- assertEvent(TreeCacheEvent.Type.NODE_REMOVED, "/test/foo");
+ assertEvent(TreeCacheEvent.Type.NODE_REMOVED, "/test/foo", "two".getBytes());
client.create().forPath("/test/foo", "two".getBytes());
assertEvent(TreeCacheEvent.Type.NODE_ADDED, "/test/foo");
@@ -428,7 +428,7 @@ public class TestTreeCache extends BaseTestTreeCache
assertEvent(TreeCacheEvent.Type.CONNECTION_SUSPENDED);
assertEvent(TreeCacheEvent.Type.CONNECTION_LOST);
assertEvent(TreeCacheEvent.Type.CONNECTION_RECONNECTED);
- assertEvent(TreeCacheEvent.Type.NODE_REMOVED, "/test/me");
+ assertEvent(TreeCacheEvent.Type.NODE_REMOVED, "/test/me", "data".getBytes());
assertNoMoreEvents();
}
@@ -460,7 +460,7 @@ public class TestTreeCache extends BaseTestTreeCache
Assert.assertEquals(new String(cache.getCurrentData("/test/one").getData()), "sup!");
client.delete().forPath("/test/one");
- assertEvent(TreeCacheEvent.Type.NODE_REMOVED, "/test/one");
+ assertEvent(TreeCacheEvent.Type.NODE_REMOVED, "/test/one", "sup!".getBytes());
Assert.assertEquals(cache.getCurrentChildren("/test").keySet(), ImmutableSet.of());
assertNoMoreEvents();
@@ -508,7 +508,7 @@ public class TestTreeCache extends BaseTestTreeCache
Assert.assertEquals(new String(cache2.getCurrentData("/test/one").getData()), "sup!");
client.delete().forPath("/test/one");
- assertEvent(TreeCacheEvent.Type.NODE_REMOVED, "/test/one");
+ assertEvent(TreeCacheEvent.Type.NODE_REMOVED, "/test/one", "sup!".getBytes());
Assert.assertNull(cache.getCurrentData("/test/one"));
semaphore.acquire();
Assert.assertNull(cache2.getCurrentData("/test/one"));