OSMQ
v2.0.1

osmq.pulsar
Class HeartbeatListener

java.lang.Object
  extended byosmq.util.Threaded
      extended byosmq.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.


Field Summary
static byte[] buffer
           
static int buffer_size
           
 
Fields inherited from class osmq.util.Threaded
HIGH_PRIORITY, HIGHEST_PRIORITY, INCREASED_PRIORITY, VERY_HIGH_PRIORITY
 
Constructor Summary
HeartbeatListener()
           
 
Method Summary
 void addListener(StateEventListener l)
           
 int getPulsarPort()
           
 int getTimeoutSeconds()
           
 void removeListener(StateEventListener l)
           
 void setPulsarPort(int p)
           
 void setTimeoutSeconds(int s)
           
 
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
 

Field Detail

buffer_size

public static int buffer_size

buffer

public static byte[] buffer
Constructor Detail

HeartbeatListener

public HeartbeatListener()
Method Detail

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)

(c) 2000 - 2003 MQue Systems
All Rights Reserved