public class RiverClusterService extends AbstractLifecycleComponent<RiverClusterService>
lifecycle
componentSettings, logger, settings
Constructor and Description |
---|
RiverClusterService(Settings settings,
TransportService transportService,
ClusterService clusterService) |
Modifier and Type | Method and Description |
---|---|
void |
add(RiverClusterStateListener listener) |
protected void |
doClose() |
protected void |
doStart() |
protected void |
doStop() |
void |
remove(RiverClusterStateListener listener) |
ClusterState |
state()
The current state.
|
void |
submitStateUpdateTask(String source,
RiverClusterStateUpdateTask updateTask) |
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop
nodeName
@Inject public RiverClusterService(Settings settings, TransportService transportService, ClusterService clusterService)
protected void doStart() throws ElasticsearchException
doStart
in class AbstractLifecycleComponent<RiverClusterService>
ElasticsearchException
protected void doStop() throws ElasticsearchException
doStop
in class AbstractLifecycleComponent<RiverClusterService>
ElasticsearchException
protected void doClose() throws ElasticsearchException
doClose
in class AbstractLifecycleComponent<RiverClusterService>
ElasticsearchException
public void add(RiverClusterStateListener listener)
public void remove(RiverClusterStateListener listener)
public ClusterState state()
public void submitStateUpdateTask(String source, RiverClusterStateUpdateTask updateTask)
Copyright © 2009–2015. All rights reserved.