public class RiversService extends AbstractLifecycleComponent<RiversService>
lifecycle
componentSettings, logger, settings
Constructor and Description |
---|
RiversService(Settings settings,
Client client,
ThreadPool threadPool,
ClusterService clusterService,
RiversTypesRegistry typesRegistry,
RiverClusterService riverClusterService,
Injector injector) |
Modifier and Type | Method and Description |
---|---|
void |
closeRiver(RiverName riverName) |
void |
createRiver(RiverName riverName,
Map<String,Object> settings) |
protected void |
doClose() |
protected void |
doStart() |
protected void |
doStop() |
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop
nodeName
@Inject public RiversService(Settings settings, Client client, ThreadPool threadPool, ClusterService clusterService, RiversTypesRegistry typesRegistry, RiverClusterService riverClusterService, Injector injector)
protected void doStart() throws ElasticsearchException
doStart
in class AbstractLifecycleComponent<RiversService>
ElasticsearchException
protected void doStop() throws ElasticsearchException
doStop
in class AbstractLifecycleComponent<RiversService>
ElasticsearchException
protected void doClose() throws ElasticsearchException
doClose
in class AbstractLifecycleComponent<RiversService>
ElasticsearchException
public void createRiver(RiverName riverName, Map<String,Object> settings) throws ElasticsearchException
ElasticsearchException
public void closeRiver(RiverName riverName) throws ElasticsearchException
ElasticsearchException
Copyright © 2009–2015. All rights reserved.