OSMQ
v2.0.1

osmq.broker.handlers
Class SubscriberHandler

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


Field Summary
 
Fields inherited from class osmq.util.Threaded
HIGH_PRIORITY, HIGHEST_PRIORITY, INCREASED_PRIORITY, VERY_HIGH_PRIORITY
 
Constructor Summary
SubscriberHandler()
           
 
Method Summary
static int getAgentCount()
           
static long getMessageCount()
           
static void killAllSubscribers()
           
static void killNamedSubscriber(java.lang.String n)
           
 
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

SubscriberHandler

public SubscriberHandler()
Method Detail

killNamedSubscriber

public static void killNamedSubscriber(java.lang.String n)

getMessageCount

public static long getMessageCount()

getAgentCount

public static int getAgentCount()

killAllSubscribers

public static void killAllSubscribers()

(c) 2000 - 2003 MQue Systems
All Rights Reserved