public class MulticastZenPing extends AbstractLifecycleComponent<ZenPing> implements ZenPing
ZenPing.PingCollection, ZenPing.PingListener, ZenPing.PingResponse
Modifier and Type | Field and Description |
---|---|
static String |
ACTION_NAME |
lifecycle
componentSettings, logger, settings
Constructor and Description |
---|
MulticastZenPing(Settings settings,
ThreadPool threadPool,
TransportService transportService,
ClusterName clusterName,
NetworkService networkService,
Version version) |
MulticastZenPing(ThreadPool threadPool,
TransportService transportService,
ClusterName clusterName,
Version version) |
Modifier and Type | Method and Description |
---|---|
protected void |
doClose() |
protected void |
doStart() |
protected void |
doStop() |
void |
ping(ZenPing.PingListener listener,
TimeValue timeout) |
ZenPing.PingResponse[] |
pingAndWait(TimeValue timeout) |
void |
setPingContextProvider(PingContextProvider nodesProvider) |
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop
nodeName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop
close
public static final String ACTION_NAME
public MulticastZenPing(ThreadPool threadPool, TransportService transportService, ClusterName clusterName, Version version)
public MulticastZenPing(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterName clusterName, NetworkService networkService, Version version)
public void setPingContextProvider(PingContextProvider nodesProvider)
setPingContextProvider
in interface ZenPing
protected void doStart() throws ElasticsearchException
doStart
in class AbstractLifecycleComponent<ZenPing>
ElasticsearchException
protected void doStop() throws ElasticsearchException
doStop
in class AbstractLifecycleComponent<ZenPing>
ElasticsearchException
protected void doClose() throws ElasticsearchException
doClose
in class AbstractLifecycleComponent<ZenPing>
ElasticsearchException
public ZenPing.PingResponse[] pingAndWait(TimeValue timeout)
public void ping(ZenPing.PingListener listener, TimeValue timeout)
Copyright © 2009–2015. All rights reserved.