@Test public void testRecreatesNodeWhenItGetsDeleted() throws Exception { PersistentEphemeralNode node = createNode(PATH, CreateMode.EPHEMERAL); String originalNode = node.getActualPath(); assertNodeExists(_curator, originalNode); _curator.delete().forPath(originalNode); WatchTrigger createdWatchTrigger = WatchTrigger.creationTrigger(); Stat stat = _curator.checkExists().usingWatcher(createdWatchTrigger).forPath(originalNode); assertTrue(stat != null || createdWatchTrigger.firedWithin(10, TimeUnit.SECONDS)); }
@VisibleForTesting String getActualPath() throws ExecutionException, InterruptedException { return _async.getActualPath(); }
PersistentEphemeralNode { @VisibleForTesting String getActualPath() throws ExecutionException, InterruptedException { return _async.getActualPath(); } }
PersistentEphemeralNode { @VisibleForTesting String getActualPath() throws ExecutionException, InterruptedException { return _async.getActualPath(); } PersistentEphemeralNode(CuratorFramework curator, String basePath, byte[] data, CreateMode mode); }
PersistentEphemeralNode { @VisibleForTesting String getActualPath() throws ExecutionException, InterruptedException { return _async.getActualPath(); } PersistentEphemeralNode(CuratorFramework curator, String basePath, byte[] data, CreateMode mode); void close(long duration, TimeUnit unit); }
PersistentEphemeralNode { @VisibleForTesting String getActualPath() throws ExecutionException, InterruptedException { return _async.getActualPath(); } PersistentEphemeralNode(CuratorFramework curator, String basePath, byte[] data, CreateMode mode); void close(long duration, TimeUnit unit);  }