@InterfaceAudience.Public @InterfaceStability.Evolving public abstract class AbstractLivelinessMonitor<O> extends AbstractService
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_EXPIRE |
Constructor and Description |
---|
AbstractLivelinessMonitor(String name) |
AbstractLivelinessMonitor(String name,
Clock clock) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
expire(O ob) |
void |
receivedPing(O ob) |
void |
register(O ob) |
void |
resetTimer() |
protected void |
serviceStart()
Actions called during the INITED to STARTED transition.
|
protected void |
serviceStop()
Actions called during the transition to the STOPPED state.
|
protected void |
setExpireInterval(int expireInterval) |
protected void |
setMonitorInterval(int monitorInterval) |
void |
unregister(O ob) |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceInit, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public static final int DEFAULT_EXPIRE
public AbstractLivelinessMonitor(String name)
protected void serviceStart() throws Exception
AbstractService
AbstractService.start()
prevents re-entrancy.serviceStart
in class AbstractService
Exception
- if needed -these will be caught,
wrapped, and trigger a service stopprotected void serviceStop() throws Exception
AbstractService
AbstractService.stop()
prevents re-entrancy.
Implementations MUST write this to be robust against failures, including
checks for null references -and for the first failure to not stop other
attempts to shut down parts of the service.serviceStop
in class AbstractService
Exception
- if needed -these will be caught and logged.protected abstract void expire(O ob)
protected void setExpireInterval(int expireInterval)
protected void setMonitorInterval(int monitorInterval)
public void receivedPing(O ob)
public void register(O ob)
public void unregister(O ob)
public void resetTimer()
Copyright © 2017 Apache Software Foundation. All rights reserved.