osmq.pulsar
Class HeartbeatListener
java.lang.Object
osmq.util.Threaded
osmq.pulsar.HeartbeatListener
- All Implemented Interfaces:
- java.lang.Runnable
- public class HeartbeatListener
- extends Threaded
An aggregate class used by a service's client to identify if and when a service fails.
The service being monitored must employ a HeartbeatTransmitter -- a ServicePulsar
transmitting at the standard "heartbeat" frequency.
The client class registers a function to be called if / when the service fails.
Methods inherited from class osmq.util.Threaded |
getExceptionListener, getIterations, getPriority, getSequenceNumber, getUserDefinedName, getYieldToPeers, hasTerminated, isPaused, isRunning, isShutdownCompleted, killAll, killAllInGroup, run, setExceptionListener, setPaused, setPriority, setUserDefinedName, setYieldCount, shutdownRequested, sleepSecs, sleepTenths, start, stop, successfulInit |
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
buffer_size
public static int buffer_size
buffer
public static byte[] buffer
HeartbeatListener
public HeartbeatListener()
setTimeoutSeconds
public void setTimeoutSeconds(int s)
getTimeoutSeconds
public int getTimeoutSeconds()
setPulsarPort
public void setPulsarPort(int p)
getPulsarPort
public int getPulsarPort()
addListener
public void addListener(StateEventListener l)
removeListener
public void removeListener(StateEventListener l)