@Test public void testDeserializeExponentialBackoffRetry() { ZooKeeperConfiguration config = parse(ImmutableMap.of("retryPolicy", ImmutableMap.builder() .put("type", "exponentialBackoff") .put("baseSleepTimeMs", 50) .put("maxRetries", 3) .build())); assertTrue(config.getRetryPolicy().get() instanceof ExponentialBackoffRetry); }
@JsonIgnore public Optional<org.apache.curator.RetryPolicy> getRetryPolicy() { if (_setterRetryPolicy.isPresent()) { return _setterRetryPolicy; } return Optional.<org.apache.curator.RetryPolicy>ofNullable(_configRetryPolicy); }
ZooKeeperConfiguration { @JsonIgnore public Optional<org.apache.curator.RetryPolicy> getRetryPolicy() { if (_setterRetryPolicy.isPresent()) { return _setterRetryPolicy; } return Optional.<org.apache.curator.RetryPolicy>ofNullable(_configRetryPolicy); } }
ZooKeeperConfiguration { @JsonIgnore public Optional<org.apache.curator.RetryPolicy> getRetryPolicy() { if (_setterRetryPolicy.isPresent()) { return _setterRetryPolicy; } return Optional.<org.apache.curator.RetryPolicy>ofNullable(_configRetryPolicy); }  }
ZooKeeperConfiguration { @JsonIgnore public Optional<org.apache.curator.RetryPolicy> getRetryPolicy() { if (_setterRetryPolicy.isPresent()) { return _setterRetryPolicy; } return Optional.<org.apache.curator.RetryPolicy>ofNullable(_configRetryPolicy); }  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 { @JsonIgnore public Optional<org.apache.curator.RetryPolicy> getRetryPolicy() { if (_setterRetryPolicy.isPresent()) { return _setterRetryPolicy; } return Optional.<org.apache.curator.RetryPolicy>ofNullable(_configRetryPolicy); }  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);  }