Package org.elasticsearch.action.support.broadcast.node

Class TransportBroadcastByNodeAction.AsyncAction

java.lang.Object

org.elasticsearch.action.support.broadcast.node.TransportBroadcastByNodeAction.AsyncAction

All Implemented Interfaces:

CancellableTask.CancellationListener

Enclosing class:

TransportBroadcastByNodeAction<Request extends BroadcastRequest<Request>,Response extends BroadcastResponse,ShardOperationResult extends Writeable>

protected class TransportBroadcastByNodeAction.AsyncAction
extends Object
implements CancellableTask.CancellationListener

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AsyncAction(Task task, Request request, ActionListener<Response> listener)

Method Summary

Modifier and Type	Method	Description
NodeResponseTracker	getNodeResponseTracker()
void	onCancelled()
protected void	onCompletion()
protected void	onNodeFailure(DiscoveryNode node, int nodeIndex, Throwable t)
protected void	onNodeResponse(DiscoveryNode node, int nodeIndex, TransportBroadcastByNodeAction<Request,Response,ShardOperationResult>.org.elasticsearch.action.support.broadcast.node.TransportBroadcastByNodeAction.NodeResponse response)
void	start()

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncAction

protected AsyncAction(Task task,
 Request request,
 ActionListener<Response> listener)

Method Details

start

public void start()

onNodeResponse

protected void onNodeResponse(DiscoveryNode node,
 int nodeIndex,
 TransportBroadcastByNodeAction<Request,Response,ShardOperationResult>.org.elasticsearch.action.support.broadcast.node.TransportBroadcastByNodeAction.NodeResponse response)

onNodeFailure

protected void onNodeFailure(DiscoveryNode node,
 int nodeIndex,
 Throwable t)

onCompletion

protected void onCompletion()

onCancelled

public void onCancelled()

Specified by:

onCancelled in interface CancellableTask.CancellationListener

getNodeResponseTracker

public NodeResponseTracker getNodeResponseTracker()