Package org.elasticsearch.discovery
Class AckClusterStatePublishResponseHandler
- java.lang.Object
-
- org.elasticsearch.discovery.BlockingClusterStatePublishResponseHandler
-
- org.elasticsearch.discovery.AckClusterStatePublishResponseHandler
-
public class AckClusterStatePublishResponseHandler extends BlockingClusterStatePublishResponseHandler
Allows to wait for all nodes to reply to the publish of a new cluster state and notifies theDiscovery.AckListener
so that the cluster state update can be acknowledged
-
-
Constructor Summary
Constructors Constructor Description AckClusterStatePublishResponseHandler(java.util.Set<DiscoveryNode> publishingToNodes, Discovery.AckListener ackListener)
Creates a new AckClusterStatePublishResponseHandler
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onFailure(DiscoveryNode node, java.lang.Exception e)
Called for each failure obtained from non master nodesvoid
onResponse(DiscoveryNode node)
Called for each response obtained from non master nodes-
Methods inherited from class org.elasticsearch.discovery.BlockingClusterStatePublishResponseHandler
awaitAllNodes, getFailedNodes, pendingNodes
-
-
-
-
Constructor Detail
-
AckClusterStatePublishResponseHandler
public AckClusterStatePublishResponseHandler(java.util.Set<DiscoveryNode> publishingToNodes, Discovery.AckListener ackListener)
Creates a new AckClusterStatePublishResponseHandler- Parameters:
publishingToNodes
- the set of nodes to which the cluster state will be published and should respondackListener
- theDiscovery.AckListener
to notify for each response gotten from non master nodes
-
-
Method Detail
-
onResponse
public void onResponse(DiscoveryNode node)
Description copied from class:BlockingClusterStatePublishResponseHandler
Called for each response obtained from non master nodes- Overrides:
onResponse
in classBlockingClusterStatePublishResponseHandler
- Parameters:
node
- the node that replied to the publish event
-
onFailure
public void onFailure(DiscoveryNode node, java.lang.Exception e)
Description copied from class:BlockingClusterStatePublishResponseHandler
Called for each failure obtained from non master nodes- Overrides:
onFailure
in classBlockingClusterStatePublishResponseHandler
- Parameters:
node
- the node that replied to the publish event
-
-