JarCastingcurator-extensions
Helpers that extend the functionality of curator.
New Recipes
<dependency>
<groupId>com.bazaarvoice.curator</groupId>
<artifactId>recipes</artifactId>
</dependency>
PersistentEphemeralNode
Ensures that as long as you have a connection to ZooKeeper that your ephemeral node stays around.
This recipe prevents node loss from:
- connection and session interruptions
- accidental deletion
NodeDiscovery
Works on top of PathChildrenCache to automatically parse the data portion of the node and notify listeners. See NodeDiscovery.NodeDataParser and NodeDiscovery.NodeListener for more info.
Easy Dropwizard Integration
<dependency>
<groupId>com.bazaarvoice.curator</groupId>
<artifactId>dropwizard</artifactId>
</dependency>
public class SampleConfiguration extends Configuration {
@Valid
@NotNull
@JsonProperty("zooKeeper")
private ZooKeeperConfiguration _zooKeeperConfiguration = new ZooKeeperConfiguration();
public ZooKeeperConfiguration getZooKeeperConfiguration() {
return _zooKeeperConfiguration;
}
}
public class SampleService extends Service<SampleConfiguration> {
public static void main(String[] args) throws Exception {
new SampleService().run(args);
}
@Override
public void initialize(... bootstrap) {
// ...
}
@Override
public void run(SampleConfiguration cfg, Environment env) {
CuratorFramework curator = cfg.getZooKeeperConfiguration().newManagedCurator(env.lifecycle());
environment..healthChecks().register("curator", new CuratorHealthCheck(curator));
}
}
