@groovy.transform.TypeChecked @java.lang.SuppressWarnings(['ThisReferenceEscapesConstructor']) abstract class AbstractTreeWatcher extends java.lang.Object
AbstractTreeWatcher defines the contract and base components for the various Zookeeper tree watchers Verspaetung needs. The responsibility of these watchers is to process events from the TreeCache and emit processed events further down the pipeline
Modifiers | Name | Description |
---|---|---|
protected org.apache.curator.framework.recipes.cache.TreeCache |
cache |
|
protected org.apache.curator.framework.CuratorFramework |
client |
|
protected org.slf4j.Logger |
logger |
|
protected java.util.List<groovy.lang.Closure> |
onInitComplete |
Constructor and description |
---|
protected AbstractTreeWatcher
(org.apache.curator.framework.CuratorFramework curatorClient) |
Type | Name and description |
---|---|
void |
childEvent(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.recipes.cache.TreeCacheEvent event) |
AbstractTreeWatcher |
close() Close our internal cache and return ourselves for API cleanliness |
AbstractTreeWatcher |
start() Start our internal cache and return ourselves for API cleanliness |
java.lang.String |
zookeeperPath() Return the String of the path in Zookeeper this class should watch. |
Methods inherited from class | Name |
---|---|
class java.lang.Object |
java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll() |
Close our internal cache and return ourselves for API cleanliness
Start our internal cache and return ourselves for API cleanliness
Return the String of the path in Zookeeper this class should watch. This method must be safe to call from the initializer of the class