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 Description protected
AsyncAction(Task task, Request request, ActionListener<Response> listener)
-
Method Summary
Modifier and Type Method 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()
-
-
-
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()
-
-