org.xbib.elasticsearch.action.plugin.jdbc.state.put

Class TransportPutRiverStateAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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

org.elasticsearch.action.support.master.TransportMasterNodeOperationAction<PutRiverStateRequest,PutRiverStateResponse>

org.xbib.elasticsearch.action.plugin.jdbc.state.put.TransportPutRiverStateAction

public class TransportPutRiverStateAction
extends org.elasticsearch.action.support.master.TransportMasterNodeOperationAction<PutRiverStateRequest,PutRiverStateResponse>

Field Summary

Fields inherited from class org.elasticsearch.action.support.master.TransportMasterNodeOperationAction

clusterService, transportService

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

actionName, threadPool

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportPutRiverStateAction(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.threadpool.ThreadPool threadPool, org.elasticsearch.cluster.ClusterService clusterService, org.elasticsearch.transport.TransportService transportService, org.elasticsearch.common.inject.Injector injector)

Method Summary

Methods

Modifier and Type	Method and Description
protected org.elasticsearch.cluster.block.ClusterBlockException	checkBlock(PutRiverStateRequest request, org.elasticsearch.cluster.ClusterState state)
protected String	executor()
protected void	masterOperation(PutRiverStateRequest request, org.elasticsearch.cluster.ClusterState state, org.elasticsearch.action.ActionListener<PutRiverStateResponse> listener)
protected PutRiverStateRequest	newRequest()
protected PutRiverStateResponse	newResponse()

Methods inherited from class org.elasticsearch.action.support.master.TransportMasterNodeOperationAction

doExecute, execute, localExecute, processBeforeDelegationToMaster

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

execute

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

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

Constructor Detail

TransportPutRiverStateAction

@Inject
public TransportPutRiverStateAction(org.elasticsearch.common.settings.Settings settings,
                                   org.elasticsearch.threadpool.ThreadPool threadPool,
                                   org.elasticsearch.cluster.ClusterService clusterService,
                                   org.elasticsearch.transport.TransportService transportService,
                                   org.elasticsearch.common.inject.Injector injector)

Method Detail

executor

protected String executor()

Specified by:

executor in class org.elasticsearch.action.support.master.TransportMasterNodeOperationAction<PutRiverStateRequest,PutRiverStateResponse>

newRequest

protected PutRiverStateRequest newRequest()

Specified by:

newRequest in class org.elasticsearch.action.support.master.TransportMasterNodeOperationAction<PutRiverStateRequest,PutRiverStateResponse>

newResponse

protected PutRiverStateResponse newResponse()

Specified by:

newResponse in class org.elasticsearch.action.support.master.TransportMasterNodeOperationAction<PutRiverStateRequest,PutRiverStateResponse>

checkBlock

protected org.elasticsearch.cluster.block.ClusterBlockException checkBlock(PutRiverStateRequest request,
                                                               org.elasticsearch.cluster.ClusterState state)

Overrides:

checkBlock in class org.elasticsearch.action.support.master.TransportMasterNodeOperationAction<PutRiverStateRequest,PutRiverStateResponse>

masterOperation

protected void masterOperation(PutRiverStateRequest request,
                   org.elasticsearch.cluster.ClusterState state,
                   org.elasticsearch.action.ActionListener<PutRiverStateResponse> listener)
                        throws org.elasticsearch.ElasticsearchException

Specified by:

masterOperation in class org.elasticsearch.action.support.master.TransportMasterNodeOperationAction<PutRiverStateRequest,PutRiverStateResponse>

Throws:

org.elasticsearch.ElasticsearchException