org.elasticsearch.cluster

Class ProcessedClusterStateUpdateTask

java.lang.Object

org.elasticsearch.cluster.ClusterStateUpdateTask

org.elasticsearch.cluster.ProcessedClusterStateUpdateTask

Direct Known Subclasses:

ProcessedClusterStateNonMasterUpdateTask, TimeoutClusterStateUpdateTask

public abstract class ProcessedClusterStateUpdateTask
extends ClusterStateUpdateTask

An extension interface to ClusterStateUpdateTask that allows to be notified when the cluster state update has been processed.

Constructor Summary

Constructors

Constructor and Description
ProcessedClusterStateUpdateTask()

Method Summary

Modifier and Type	Method and Description
abstract void	clusterStateProcessed(String source, ClusterState oldState, ClusterState newState) Called when the result of the ClusterStateUpdateTask.execute(ClusterState) have been processed properly by all listeners.

Methods inherited from class org.elasticsearch.cluster.ClusterStateUpdateTask

execute, onFailure, onNoLongerMaster, runOnlyOnMaster

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessedClusterStateUpdateTask

public ProcessedClusterStateUpdateTask()

Method Detail

clusterStateProcessed

public abstract void clusterStateProcessed(String source,
                                           ClusterState oldState,
                                           ClusterState newState)

Called when the result of the ClusterStateUpdateTask.execute(ClusterState) have been processed properly by all listeners.