org.elasticsearch.action.support.broadcast.node

Class TransportBroadcastByNodeAction.AsyncAction

java.lang.Object

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

Enclosing class:

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

protected class TransportBroadcastByNodeAction.AsyncAction
extends java.lang.Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	onCompletion()
protected void	onNodeFailure(DiscoveryNode node, int nodeIndex, java.lang.Throwable t)
protected void	onNodeResponse(DiscoveryNode node, int nodeIndex, 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 Detail

AsyncAction

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

Method Detail

start

public void start()

onNodeResponse

protected void onNodeResponse(DiscoveryNode node,
                              int nodeIndex,
                              org.elasticsearch.action.support.broadcast.node.TransportBroadcastByNodeAction.NodeResponse response)

onNodeFailure

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

onCompletion

protected void onCompletion()