OSMQ
v2.0.1

osmq.broker.handlers
Class RecoveryHandler

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


Field Summary
 
Fields inherited from class osmq.util.Threaded
HIGH_PRIORITY, HIGHEST_PRIORITY, INCREASED_PRIORITY, VERY_HIGH_PRIORITY
 
Constructor Summary
RecoveryHandler()
           
 
Method Summary
static int getAgentCount()
           
static long getMessageCount()
           
static PersistableMQue getRecoveryQueue()
           
static void killAllSubscribers()
           
 
Methods inherited from class osmq.broker.handlers.ServiceHandler
getRemoteIPString, getStreamFilter, println, readBytes, readln, setParent, setStreamFilter, writeBytes
 
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
 

Constructor Detail

RecoveryHandler

public RecoveryHandler()
Method Detail

getRecoveryQueue

public static final PersistableMQue getRecoveryQueue()

getMessageCount

public static long getMessageCount()

getAgentCount

public static int getAgentCount()

killAllSubscribers

public static void killAllSubscribers()

(c) 2000 - 2003 MQue Systems
All Rights Reserved