Package org.apache.camel.component.zookeeper.operations

Class ExistenceChangedOperation

java.lang.Object

org.apache.camel.component.zookeeper.operations.ZooKeeperOperation<String>

org.apache.camel.component.zookeeper.operations.FutureEventDrivenOperation<String>

org.apache.camel.component.zookeeper.operations.ExistenceChangedOperation

All Implemented Interfaces:

WatchedEventProvider, org.apache.zookeeper.Watcher

public class ExistenceChangedOperation
extends FutureEventDrivenOperation<String>

DataChangedOperation is an watch driven operation. It will wait for an watched event indicating that a given node has been created or deleted.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

org.apache.zookeeper.Watcher.Event, org.apache.zookeeper.Watcher.WatcherType

Field Summary

Fields inherited from class org.apache.camel.component.zookeeper.operations.ZooKeeperOperation

connection, CONSTRUCTOR_ARGS, LOG, node, result, waitingThreads

Constructor Summary

Constructors

Constructor	Description
ExistenceChangedOperation(org.apache.zookeeper.ZooKeeper connection, String znode)

Method Summary

Modifier and Type	Method	Description
OperationResult<String>	getResult()	Gets the result of this zookeeper operation, i.e. some data and the associated node stats
protected void	installWatch()	Install the watcher to receive WatchedEvents.

Methods inherited from class org.apache.camel.component.zookeeper.operations.FutureEventDrivenOperation

get, get, getWatchedEvent, getWatchedForTypes, process

Methods inherited from class org.apache.camel.component.zookeeper.operations.ZooKeeperOperation

cancel, createCopy, getNode, isCancelled, isDone, shouldProduceExchange

Methods inherited from class java.lang.Object

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

Constructor Details

ExistenceChangedOperation

public ExistenceChangedOperation(org.apache.zookeeper.ZooKeeper connection,
 String znode)

Method Details

installWatch

protected void installWatch()

Description copied from class: FutureEventDrivenOperation

Install the watcher to receive WatchedEvents. It should use the appropriate asynchronous ZooKeeper call to do this so as not to block the route from starting. Once one of the watched for types of event is received a call is made to getResult, which can use the appropriate synchronous call to retrieve the actual data.

Specified by:

installWatch in class FutureEventDrivenOperation<String>

getResult

public OperationResult<String> getResult()

Description copied from class: ZooKeeperOperation

Gets the result of this zookeeper operation, i.e. some data and the associated node stats

Specified by:

getResult in class ZooKeeperOperation<String>