public class RiversRouter extends AbstractLifecycleComponent<RiversRouter> implements ClusterStateListener
lifecycle
componentSettings, logger, settings
Constructor and Description |
---|
RiversRouter(Settings settings,
Client client,
ClusterService clusterService,
RiverClusterService riverClusterService,
ThreadPool threadPool) |
Modifier and Type | Method and Description |
---|---|
void |
clusterChanged(ClusterChangedEvent event)
Called when cluster state changes.
|
protected void |
doClose() |
protected void |
doStart() |
protected void |
doStop() |
protected RiverClusterState |
updateRiverClusterState(String source,
RiverClusterState currentState,
ClusterState newClusterState,
CountDown countDown) |
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop
nodeName
@Inject public RiversRouter(Settings settings, Client client, ClusterService clusterService, RiverClusterService riverClusterService, ThreadPool threadPool)
protected void doStart() throws ElasticsearchException
doStart
in class AbstractLifecycleComponent<RiversRouter>
ElasticsearchException
protected void doStop() throws ElasticsearchException
doStop
in class AbstractLifecycleComponent<RiversRouter>
ElasticsearchException
protected void doClose() throws ElasticsearchException
doClose
in class AbstractLifecycleComponent<RiversRouter>
ElasticsearchException
public void clusterChanged(ClusterChangedEvent event)
ClusterStateListener
clusterChanged
in interface ClusterStateListener
protected RiverClusterState updateRiverClusterState(String source, RiverClusterState currentState, ClusterState newClusterState, CountDown countDown)
Copyright © 2009–2015. All rights reserved.