osmq.broker.handlers
Class SubscriberHandler
java.lang.Object
osmq.util.Threaded
osmq.broker.handlers.ServiceHandler
osmq.broker.handlers.SubscriberHandler
- All Implemented Interfaces:
- java.lang.Runnable
- public final class SubscriberHandler
- 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.
If a subscriber with a duplicate name attempts to connect,
that second connection is refused.
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 |
SubscriberHandler
public SubscriberHandler()
killNamedSubscriber
public static void killNamedSubscriber(java.lang.String n)
getMessageCount
public static long getMessageCount()
getAgentCount
public static int getAgentCount()
killAllSubscribers
public static void killAllSubscribers()