OSMQ
v2.0.1

osmq.broker.handlers
Class TopicChangeHandler

java.lang.Object
  extended byosmq.util.Threaded
      extended byosmq.broker.handlers.ServiceHandler
          extended byosmq.broker.handlers.TopicChangeHandler
All Implemented Interfaces:
java.lang.Runnable

public final class TopicChangeHandler
extends ServiceHandler

An aggregate of the MRouter class that listens on a multicast channgel for topic change requests and updates a RouterMux to reflect the change (Add or drop a topic/subscriber pair).


Field Summary
 
Fields inherited from class osmq.util.Threaded
HIGH_PRIORITY, HIGHEST_PRIORITY, INCREASED_PRIORITY, VERY_HIGH_PRIORITY
 
Constructor Summary
TopicChangeHandler()
           
 
Method Summary
static void terminateAllChildren()
           
 
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

TopicChangeHandler

public TopicChangeHandler()
Method Detail

terminateAllChildren

public static void terminateAllChildren()

(c) 2000 - 2003 MQue Systems
All Rights Reserved