org.xbib.elasticsearch.action.cluster.admin.websocket

Class TransportWebsocketInfoAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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

org.elasticsearch.action.support.nodes.TransportNodesOperationAction<WebsocketInfoRequest,WebsocketInfoResponse,org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest,WebsocketInfo>

org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction

public class TransportWebsocketInfoAction
extends org.elasticsearch.action.support.nodes.TransportNodesOperationAction<WebsocketInfoRequest,WebsocketInfoResponse,org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest,WebsocketInfo>

Field Summary

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

clusterName, 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
TransportWebsocketInfoAction(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.cluster.ClusterName clusterName, org.elasticsearch.threadpool.ThreadPool threadPool, org.elasticsearch.cluster.ClusterService clusterService, org.elasticsearch.transport.TransportService transportService, org.elasticsearch.discovery.Discovery discovery, HttpServer httpServer)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	accumulateExceptions()
protected String	executor()
protected org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest	newNodeRequest()
protected org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest	newNodeRequest(String nodeId, WebsocketInfoRequest request)
protected WebsocketInfo	newNodeResponse()
protected WebsocketInfoRequest	newRequest()
protected WebsocketInfoResponse	newResponse(WebsocketInfoRequest nodesInfoRequest, AtomicReferenceArray responses)
protected WebsocketInfo	nodeOperation(org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest nodeRequest)

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

doExecute, filterNodeIds, transportCompress

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

execute, 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

TransportWebsocketInfoAction

@Inject
public TransportWebsocketInfoAction(org.elasticsearch.common.settings.Settings settings,
                                   org.elasticsearch.cluster.ClusterName clusterName,
                                   org.elasticsearch.threadpool.ThreadPool threadPool,
                                   org.elasticsearch.cluster.ClusterService clusterService,
                                   org.elasticsearch.transport.TransportService transportService,
                                   org.elasticsearch.discovery.Discovery discovery,
                                   HttpServer httpServer)

Method Detail

executor

protected String executor()

Specified by:

executor in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<WebsocketInfoRequest,WebsocketInfoResponse,org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest,WebsocketInfo>

newResponse

protected WebsocketInfoResponse newResponse(WebsocketInfoRequest nodesInfoRequest,
                                AtomicReferenceArray responses)

Specified by:

newResponse in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<WebsocketInfoRequest,WebsocketInfoResponse,org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest,WebsocketInfo>

newRequest

protected WebsocketInfoRequest newRequest()

Specified by:

newRequest in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<WebsocketInfoRequest,WebsocketInfoResponse,org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest,WebsocketInfo>

newNodeRequest

protected org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest newNodeRequest()

Specified by:

newNodeRequest in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<WebsocketInfoRequest,WebsocketInfoResponse,org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest,WebsocketInfo>

newNodeRequest

protected org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest newNodeRequest(String nodeId,
                                                                                                                              WebsocketInfoRequest request)

Specified by:

newNodeRequest in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<WebsocketInfoRequest,WebsocketInfoResponse,org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest,WebsocketInfo>

newNodeResponse

protected WebsocketInfo newNodeResponse()

Specified by:

newNodeResponse in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<WebsocketInfoRequest,WebsocketInfoResponse,org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest,WebsocketInfo>

nodeOperation

protected WebsocketInfo nodeOperation(org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest nodeRequest)
                               throws org.elasticsearch.ElasticsearchException

Specified by:

nodeOperation in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<WebsocketInfoRequest,WebsocketInfoResponse,org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest,WebsocketInfo>

Throws:

org.elasticsearch.ElasticsearchException

accumulateExceptions

protected boolean accumulateExceptions()

Specified by:

accumulateExceptions in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<WebsocketInfoRequest,WebsocketInfoResponse,org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction.TransportWebsocketInfoRequest,WebsocketInfo>