Skip to content

Instantly share code, notes, and snippets.

@ryantenney
Created March 24, 2014 15:13
Show Gist options
  • Save ryantenney/9742132 to your computer and use it in GitHub Desktop.
Save ryantenney/9742132 to your computer and use it in GitHub Desktop.
@Bean
@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
public ZooKeeperAnnotationBeanPostProcessor zooKeeperAnnotationBeanPostProcessor() {
ZooKeeperAnnotationBeanPostProcessor proc = new ZooKeeperAnnotationBeanPostProcessor();
proc.setCuratorFramework(curatorFramework());
return proc;
}
@Bean
@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
public CuratorFramework curatorFramework() {
CuratorFrameworkFactory.Builder builder = CuratorFrameworkFactory.builder();
builder.connectString(connectString);
builder.retryPolicy(new ExponentialBackoffRetry(1000, 3));
builder.sessionTimeoutMs(sessionTimeout);
builder.namespace(namespace);
CuratorFramework curator = builder.build();
curator.start();
return curator;
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment