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 Writeable>
-
Constructor Summary
ModifierConstructorDescriptionprotected
AsyncAction
(Task task, Request request, ActionListener<Response> listener) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
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()
-
Constructor Details
-
AsyncAction
-
-
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
-
onCompletion
protected void onCompletion()
-