Skip to content

Instantly share code, notes, and snippets.

@iocanel
Last active August 29, 2015 14:09
Show Gist options
  • Save iocanel/87a2676851d3a6c982f1 to your computer and use it in GitHub Desktop.
Save iocanel/87a2676851d3a6c982f1 to your computer and use it in GitHub Desktop.
EnsembleTracker and DynamicEnsembleProvider?
//Create the ensemble provider and feed the initial string
DynamicEnsembleProvider dynamicEnsembleProvider = new DynamicEnsembleProvider(cluster.getConnectString());
CuratorFramework client = CuratorFrameworkFactory.builder()
.ensembleProvider(dynamicEnsembleProvider)
.retryPolicy(new RetryOneTime(1000))
.build();
client.start();
client.blockUntilConnected();
//Create the tracker and add the dynamic ensemble provider as a listener.
EnsembleTracker ensembleTracker = new EnsembleTracker(client);
ensembleTracker.getListenable().addListener(dynamicEnsembleProvider);
ensembleTracker.start();
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment