Package com.floragunn.searchsupport.jobs.actions

Class TransportCheckForExecutingTriggerAction

java.lang.Object

org.elasticsearch.action.support.TransportAction<Request,Response>

org.elasticsearch.action.support.HandledTransportAction<NodesRequest,NodesResponse>

org.elasticsearch.action.support.nodes.TransportNodesAction<CheckForExecutingTriggerRequest,CheckForExecutingTriggerResponse,TransportCheckForExecutingTriggerAction.NodeRequest,TransportCheckForExecutingTriggerAction.NodeResponse>

com.floragunn.searchsupport.jobs.actions.TransportCheckForExecutingTriggerAction

public class TransportCheckForExecutingTriggerAction
extends org.elasticsearch.action.support.nodes.TransportNodesAction<CheckForExecutingTriggerRequest,CheckForExecutingTriggerResponse,TransportCheckForExecutingTriggerAction.NodeRequest,TransportCheckForExecutingTriggerAction.NodeResponse>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TransportCheckForExecutingTriggerAction.NodeRequest
static class	TransportCheckForExecutingTriggerAction.NodeResponse

Field Summary

Fields inherited from class org.elasticsearch.action.support.nodes.TransportNodesAction

clusterService, nodeResponseClass, threadPool, transportNodeAction, transportService

Fields inherited from class org.elasticsearch.action.support.TransportAction

actionName, localConnection, logger, taskManager

Constructor Summary

Constructors

Constructor	Description
TransportCheckForExecutingTriggerAction(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.threadpool.ThreadPool threadPool, org.elasticsearch.cluster.service.ClusterService clusterService, org.elasticsearch.transport.TransportService transportService, org.elasticsearch.action.support.ActionFilters actionFilters)

Method Summary

Modifier and Type	Method	Description
protected TransportCheckForExecutingTriggerAction.NodeRequest	newNodeRequest(CheckForExecutingTriggerRequest request)
protected TransportCheckForExecutingTriggerAction.NodeResponse	newNodeResponse(org.elasticsearch.common.io.stream.StreamInput in)
protected CheckForExecutingTriggerResponse	newResponse(CheckForExecutingTriggerRequest request, List<TransportCheckForExecutingTriggerAction.NodeResponse> responses, List<org.elasticsearch.action.FailedNodeException> failures)
protected TransportCheckForExecutingTriggerAction.NodeResponse	nodeOperation(TransportCheckForExecutingTriggerAction.NodeRequest request)

Methods inherited from class org.elasticsearch.action.support.nodes.TransportNodesAction

doExecute, getTransportNodeAction, newResponseAsync, nodeOperation, resolveRequest

Methods inherited from class org.elasticsearch.action.support.TransportAction

execute, execute, execute

Methods inherited from class java.lang.Object

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

Constructor Detail

TransportCheckForExecutingTriggerAction

@Inject
public TransportCheckForExecutingTriggerAction(org.elasticsearch.common.settings.Settings settings,
                                               org.elasticsearch.threadpool.ThreadPool threadPool,
                                               org.elasticsearch.cluster.service.ClusterService clusterService,
                                               org.elasticsearch.transport.TransportService transportService,
                                               org.elasticsearch.action.support.ActionFilters actionFilters)

Method Detail

newResponse

protected CheckForExecutingTriggerResponse newResponse(CheckForExecutingTriggerRequest request,
                                                       List<TransportCheckForExecutingTriggerAction.NodeResponse> responses,
                                                       List<org.elasticsearch.action.FailedNodeException> failures)

Specified by:

newResponse in class org.elasticsearch.action.support.nodes.TransportNodesAction<CheckForExecutingTriggerRequest,CheckForExecutingTriggerResponse,TransportCheckForExecutingTriggerAction.NodeRequest,TransportCheckForExecutingTriggerAction.NodeResponse>

nodeOperation

protected TransportCheckForExecutingTriggerAction.NodeResponse nodeOperation(TransportCheckForExecutingTriggerAction.NodeRequest request)

Specified by:

nodeOperation in class org.elasticsearch.action.support.nodes.TransportNodesAction<CheckForExecutingTriggerRequest,CheckForExecutingTriggerResponse,TransportCheckForExecutingTriggerAction.NodeRequest,TransportCheckForExecutingTriggerAction.NodeResponse>

newNodeRequest

protected TransportCheckForExecutingTriggerAction.NodeRequest newNodeRequest(CheckForExecutingTriggerRequest request)

Specified by:

newNodeRequest in class org.elasticsearch.action.support.nodes.TransportNodesAction<CheckForExecutingTriggerRequest,CheckForExecutingTriggerResponse,TransportCheckForExecutingTriggerAction.NodeRequest,TransportCheckForExecutingTriggerAction.NodeResponse>

newNodeResponse

protected TransportCheckForExecutingTriggerAction.NodeResponse newNodeResponse(org.elasticsearch.common.io.stream.StreamInput in)
                                                                        throws IOException

Specified by:

newNodeResponse in class org.elasticsearch.action.support.nodes.TransportNodesAction<CheckForExecutingTriggerRequest,CheckForExecutingTriggerResponse,TransportCheckForExecutingTriggerAction.NodeRequest,TransportCheckForExecutingTriggerAction.NodeResponse>

Throws:

IOException