Class Summary |
ChangeHandler |
An aggregate of the MRouter class that listens on a multicast
channgel for remote commands such as kill a subscriber or shut down
the message broker |
PublisherHandler |
|
PubStatus |
|
RecoveryHandler |
Class that handles subscriber connections to the message broker. |
ServerSocketProcessor |
Listens for socket connections from publishers, subscribers, topic changers, and other
valid clients, passing each to a dedicated worker thread of the correct type. |
ServiceHandler |
|
SubscriberHandler |
Class that handles subscriber connections to the message broker. |
TopicChangeHandler |
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). |