osmq.pulsar
Class DatasetPulsarListener
java.lang.Object
osmq.util.Threaded
osmq.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.
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 |
buffer_size
public static int buffer_size
buffer
public static byte[] buffer
DatasetPulsarListener
public DatasetPulsarListener()
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