Repository: curator Updated Branches: refs/heads/CURATOR-397 09f9bc06a -> 7e6551f3f
no need to use EnsureContainers object Project: http://git-wip-us.apache.org/repos/asf/curator/repo Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/738c3617 Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/738c3617 Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/738c3617 Branch: refs/heads/CURATOR-397 Commit: 738c3617ee4887fefcf8dd5082b9b71c9f7021db Parents: 09f9bc0 Author: randgalt <[email protected]> Authored: Thu Jun 29 23:20:45 2017 -0500 Committer: randgalt <[email protected]> Committed: Thu Jun 29 23:20:45 2017 -0500 ---------------------------------------------------------------------- .../main/java/org/apache/curator/x/async/AsyncWrappers.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/curator/blob/738c3617/curator-x-async/src/main/java/org/apache/curator/x/async/AsyncWrappers.java ---------------------------------------------------------------------- diff --git a/curator-x-async/src/main/java/org/apache/curator/x/async/AsyncWrappers.java b/curator-x-async/src/main/java/org/apache/curator/x/async/AsyncWrappers.java index 8ff507c..e982cf2 100644 --- a/curator-x-async/src/main/java/org/apache/curator/x/async/AsyncWrappers.java +++ b/curator-x-async/src/main/java/org/apache/curator/x/async/AsyncWrappers.java @@ -18,7 +18,6 @@ */ package org.apache.curator.x.async; -import org.apache.curator.framework.EnsureContainers; import org.apache.curator.framework.recipes.locks.InterProcessLock; import org.apache.curator.utils.ThreadUtils; import org.apache.curator.x.async.modeled.ZPath; @@ -67,7 +66,8 @@ import java.util.concurrent.TimeUnit; public class AsyncWrappers { /** - * Asynchronously call {@link org.apache.curator.framework.EnsureContainers} using the {@link java.util.concurrent.ForkJoinPool#commonPool()}. + * Asynchronously call {@link org.apache.curator.framework.CuratorFramework#createContainers(String)} using + * the {@link java.util.concurrent.ForkJoinPool#commonPool()}. * * @param client client * @param path path to ensure @@ -79,7 +79,8 @@ public class AsyncWrappers } /** - * Asynchronously call {@link org.apache.curator.framework.EnsureContainers} using the given executor + * Asynchronously call {@link org.apache.curator.framework.CuratorFramework#createContainers(String)} using + * the given executor * * @param client client * @param path path to ensure @@ -90,7 +91,7 @@ public class AsyncWrappers Runnable proc = () -> { try { - new EnsureContainers(client.unwrap(), path.fullPath()).ensure(); + client.unwrap().createContainers(path.fullPath()); } catch ( Exception e ) {
