org.togglz.zookeeper

Class ZookeeperStateRepository

java.lang.Object

org.togglz.zookeeper.ZookeeperStateRepository

All Implemented Interfaces:

org.apache.curator.framework.recipes.cache.TreeCacheListener, StateRepository

public class ZookeeperStateRepository
extends Object
implements StateRepository, org.apache.curator.framework.recipes.cache.TreeCacheListener

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ZookeeperStateRepository.Builder

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.curator.framework.CuratorFramework	curatorFramework
protected String	featuresZnode
protected CountDownLatch	initializationLatch

Method Summary

Modifier and Type	Method and Description
void	childEvent(org.apache.curator.framework.CuratorFramework curatorFramework, org.apache.curator.framework.recipes.cache.TreeCacheEvent event)
FeatureState	getFeatureState(Feature feature)
static ZookeeperStateRepository.Builder	newBuilder(org.apache.curator.framework.CuratorFramework curatorFramework, String featuresZnode)
void	setFeatureState(FeatureState featureState)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

curatorFramework

protected final org.apache.curator.framework.CuratorFramework curatorFramework

featuresZnode

protected final String featuresZnode

initializationLatch

protected CountDownLatch initializationLatch

Method Detail

getFeatureState

public FeatureState getFeatureState(Feature feature)

Specified by:

getFeatureState in interface StateRepository

setFeatureState

public void setFeatureState(FeatureState featureState)

Specified by:

setFeatureState in interface StateRepository

childEvent

public void childEvent(org.apache.curator.framework.CuratorFramework curatorFramework,
                       org.apache.curator.framework.recipes.cache.TreeCacheEvent event)
                throws Exception

Specified by:

childEvent in interface org.apache.curator.framework.recipes.cache.TreeCacheListener

Throws:

Exception

newBuilder

public static ZookeeperStateRepository.Builder newBuilder(org.apache.curator.framework.CuratorFramework curatorFramework,
                                                          String featuresZnode)