@Test public void testEnsurePath() throws Exception { Timing timing = new Timing(); CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new RetryOneTime(1)); client.start(); try { try ( PathChildrenCache cache = new PathChildrenCache(client, "/one/two/three", false) ) { cache.start(); timing.sleepABit(); try { client.create().forPath("/one/two/three/four"); } catch ( KeeperException.NoNodeException e ) { Assert.fail("Path should exist", e); } } timing.sleepABit(); } finally { TestCleanState.closeAndTestClean(client); } }
protected void ensurePath() throws Exception { ensureContainers.ensure(); }
PathChildrenCache implements Closeable { protected void ensurePath() throws Exception { ensureContainers.ensure(); } }
PathChildrenCache implements Closeable { protected void ensurePath() throws Exception { ensureContainers.ensure(); } @Deprecated @SuppressWarnings("deprecation")  PathChildrenCache(CuratorFramework client, String path, PathChildrenCacheMode mode); @Deprecated @SuppressWarnings("deprecation")  PathChildrenCache(CuratorFramework client, String path, PathChildrenCacheMode mode, ThreadFactory threadFactory);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData, ThreadFactory threadFactory);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData, boolean dataIsCompressed, ThreadFactory threadFactory);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData, boolean dataIsCompressed, final ExecutorService executorService);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData, boolean dataIsCompressed, final CloseableExecutorService executorService); }
PathChildrenCache implements Closeable { protected void ensurePath() throws Exception { ensureContainers.ensure(); } @Deprecated @SuppressWarnings("deprecation")  PathChildrenCache(CuratorFramework client, String path, PathChildrenCacheMode mode); @Deprecated @SuppressWarnings("deprecation")  PathChildrenCache(CuratorFramework client, String path, PathChildrenCacheMode mode, ThreadFactory threadFactory);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData, ThreadFactory threadFactory);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData, boolean dataIsCompressed, ThreadFactory threadFactory);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData, boolean dataIsCompressed, final ExecutorService executorService);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData, boolean dataIsCompressed, final CloseableExecutorService executorService); void start(); @Deprecated void start(boolean buildInitial); void start(StartMode mode); void rebuild(); void rebuildNode(String fullPath); @Override void close(); ListenerContainer<PathChildrenCacheListener> getListenable(); List<ChildData> getCurrentData(); ChildData getCurrentData(String fullPath); void clearDataBytes(String fullPath); boolean clearDataBytes(String fullPath, int ifVersion); void clearAndRefresh(); void clear(); }
PathChildrenCache implements Closeable { protected void ensurePath() throws Exception { ensureContainers.ensure(); } @Deprecated @SuppressWarnings("deprecation")  PathChildrenCache(CuratorFramework client, String path, PathChildrenCacheMode mode); @Deprecated @SuppressWarnings("deprecation")  PathChildrenCache(CuratorFramework client, String path, PathChildrenCacheMode mode, ThreadFactory threadFactory);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData, ThreadFactory threadFactory);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData, boolean dataIsCompressed, ThreadFactory threadFactory);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData, boolean dataIsCompressed, final ExecutorService executorService);  PathChildrenCache(CuratorFramework client, String path, boolean cacheData, boolean dataIsCompressed, final CloseableExecutorService executorService); void start(); @Deprecated void start(boolean buildInitial); void start(StartMode mode); void rebuild(); void rebuildNode(String fullPath); @Override void close(); ListenerContainer<PathChildrenCacheListener> getListenable(); List<ChildData> getCurrentData(); ChildData getCurrentData(String fullPath); void clearDataBytes(String fullPath); boolean clearDataBytes(String fullPath, int ifVersion); void clearAndRefresh(); void clear(); static final ThreadFactory defaultThreadFactory; }