@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,
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, Clock clock)
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 void setExpireInterval(int expireInterval)
protected void setMonitorInterval(int monitorInterval)
public void receivedPing(O ob)
public void unregister(O ob)
public void resetTimer()
Copyright © 2015 Apache Software Foundation. All rights reserved.