OSMQ
v2.0.1

osmq.pulsar
Class DatasetPulsarListener

java.lang.Object
  extended byosmq.util.Threaded
      extended byosmq.pulsar.DatasetPulsarListener
All Implemented Interfaces:
java.lang.Runnable

public class DatasetPulsarListener
extends Threaded

Aggregate class used by a service's client to identify if and when a service fails. The service being monitored must employ a MulticastPulsar at the standard "pulsar" 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
DatasetPulsarListener()
           
 
Method Summary
 DataRecordListener getDataRecordListener()
           
 ExceptionListener getExceptionListener()
           
 int getPulsarPort()
           
 int getTimeoutSeconds()
           
 void setDataRecordListener(DataRecordListener l)
           
 void setExceptionListener(ExceptionListener listener)
          Registers a listener that will be notified if the thread is being halted due to an exception that was thrown by the derived class's iterativeProcess() method.
 void setPulsarPort(int p)
           
 void setTimeoutSeconds(int s)
           
 
Methods inherited from class osmq.util.Threaded
getIterations, getPriority, getSequenceNumber, getUserDefinedName, getYieldToPeers, hasTerminated, isPaused, isRunning, isShutdownCompleted, killAll, killAllInGroup, run, 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

DatasetPulsarListener

public DatasetPulsarListener()
Method Detail

setTimeoutSeconds

public void setTimeoutSeconds(int s)

getTimeoutSeconds

public int getTimeoutSeconds()

setPulsarPort

public void setPulsarPort(int p)

getPulsarPort

public int getPulsarPort()

setDataRecordListener

public void setDataRecordListener(DataRecordListener l)

getDataRecordListener

public DataRecordListener getDataRecordListener()

setExceptionListener

public void setExceptionListener(ExceptionListener listener)
Description copied from class: Threaded
Registers a listener that will be notified if the thread is being halted due to an exception that was thrown by the derived class's iterativeProcess() method.

Overrides:
setExceptionListener in class Threaded

getExceptionListener

public ExceptionListener getExceptionListener()
Overrides:
getExceptionListener in class Threaded

(c) 2000 - 2003 MQue Systems
All Rights Reserved