@Test public void testNewManagedCurator() { ZooKeeperConfiguration config = parse(ImmutableMap.of("retryPolicy", ImmutableMap.builder() .put("type", "untilElapsed") .put("maxElapsedTimeMs", 1000) .put("sleepMsBetweenRetries", 50) .build())); LifecycleEnvironment env = mock(LifecycleEnvironment.class); CuratorFramework curator = config.newManagedCurator(env); assertNotNull(curator); assertEquals(CuratorFrameworkState.LATENT, curator.getState()); verify(env).manage(any(ManagedCuratorFramework.class)); }
@Deprecated public CuratorFramework newManagedCurator(Environment env) { return newManagedCurator(env.lifecycle()); }
ZooKeeperConfiguration { @Deprecated public CuratorFramework newManagedCurator(Environment env) { return newManagedCurator(env.lifecycle()); } }
ZooKeeperConfiguration { @Deprecated public CuratorFramework newManagedCurator(Environment env) { return newManagedCurator(env.lifecycle()); }  }
ZooKeeperConfiguration { @Deprecated public CuratorFramework newManagedCurator(Environment env) { return newManagedCurator(env.lifecycle()); }  CuratorFramework newCurator(); @Deprecated CuratorFramework newManagedCurator(Environment env); CuratorFramework newManagedCurator(LifecycleEnvironment env); @JsonIgnore Optional<String> getConnectString(); @JsonIgnore Optional<String> getNamespace(); @JsonIgnore Optional<org.apache.curator.RetryPolicy> getRetryPolicy(); @JsonIgnore void setConnectString(String connectString); @JsonIgnore void setNamespace(String namespace); @JsonIgnore void setRetryPolicy(org.apache.curator.RetryPolicy retryPolicy); }
ZooKeeperConfiguration { @Deprecated public CuratorFramework newManagedCurator(Environment env) { return newManagedCurator(env.lifecycle()); }  CuratorFramework newCurator(); @Deprecated CuratorFramework newManagedCurator(Environment env); CuratorFramework newManagedCurator(LifecycleEnvironment env); @JsonIgnore Optional<String> getConnectString(); @JsonIgnore Optional<String> getNamespace(); @JsonIgnore Optional<org.apache.curator.RetryPolicy> getRetryPolicy(); @JsonIgnore void setConnectString(String connectString); @JsonIgnore void setNamespace(String namespace); @JsonIgnore void setRetryPolicy(org.apache.curator.RetryPolicy retryPolicy);  }