|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectist.palcom.routing.util.RoutingPubSubManager
public class RoutingPubSubManager
A class that manages topic-based publish/subscribe communication.
| Field Summary | |
|---|---|
protected MediaManager |
mediaManager
The MediaManager used for network communication |
protected PalcomScheduler |
scheduler
|
protected boolean |
started
True while started. |
| Constructor Summary | |
|---|---|
RoutingPubSubManager(PalcomScheduler scheduler,
AbstractRoutingManager routingManager)
|
|
RoutingPubSubManager(PalcomScheduler scheduler,
MediaManager mediaManager)
|
|
| Method Summary | |
|---|---|
protected void |
broadcastMessage(java.lang.String topic,
Message message,
Selector senderSelector)
Broadcasts a message with a certain topic out to the network. |
void |
publish(java.lang.String topic,
Message message,
Selector publisherSelector)
Publish a message on a topic. |
void |
stop()
Stops the PubSubManager. |
void |
subscribe(java.lang.String topic,
PalcomThread subscriber)
Subscribe to a topic. |
void |
unsubscribe(java.lang.String topic,
PalcomThread subscriber)
Stop subscribing to a topic. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
protected final PalcomScheduler scheduler
protected final MediaManager mediaManager
protected boolean started
| Constructor Detail |
|---|
public RoutingPubSubManager(PalcomScheduler scheduler,
MediaManager mediaManager)
public RoutingPubSubManager(PalcomScheduler scheduler,
AbstractRoutingManager routingManager)
| Method Detail |
|---|
public void stop()
public void subscribe(java.lang.String topic,
PalcomThread subscriber)
public void unsubscribe(java.lang.String topic,
PalcomThread subscriber)
public void publish(java.lang.String topic,
Message message,
Selector publisherSelector)
protected void broadcastMessage(java.lang.String topic,
Message message,
Selector senderSelector)
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||