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-3.0 Commit: 0a3240f05bff69a87dd6a743d3afac61f8954494 Parents: 6b8113b Author: randgalt <[email protected]> Authored: Fri Jan 15 12:47:33 2016 -0500 Committer: randgalt <[email protected]> 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"));
