@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) |
protected long |
getExpireInterval(O o) |
void |
receivedPing(O ob) |
void |
register(O ob) |
void |
register(O ob,
long expireTime) |
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(long expireInterval) |
protected void |
setMonitorInterval(long monitorInterval) |
protected void |
setResetTimeOnStart(boolean resetTimeOnStart) |
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(long expireInterval)
protected long getExpireInterval(O o)
protected void setMonitorInterval(long monitorInterval)
public void receivedPing(O ob)
public void register(O ob)
public void register(O ob, long expireTime)
public void unregister(O ob)
public void resetTimer()
protected void setResetTimeOnStart(boolean resetTimeOnStart)
Copyright © 2024 Apache Software Foundation. All rights reserved.