osmq.broker.handlers
Class RecoveryHandler
java.lang.Object
osmq.util.Threaded
osmq.broker.handlers.ServiceHandler
osmq.broker.handlers.RecoveryHandler
- All Implemented Interfaces:
- java.lang.Runnable
- public final class RecoveryHandler
- extends ServiceHandler
Class that handles subscriber connections to the message broker.
The startWorker function must create a descendent of class WorkerSock,
and SubscriberHandler creates an instance that handles passing
topical and point-to-point messages to subscribers.
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 |
RecoveryHandler
public RecoveryHandler()
getRecoveryQueue
public static final PersistableMQue getRecoveryQueue()
getMessageCount
public static long getMessageCount()
getAgentCount
public static int getAgentCount()
killAllSubscribers
public static void killAllSubscribers()