org.agilewiki.jactor.pubsub.publisher

Class JAPublisher

java.lang.Object

org.agilewiki.jactor.lpc.JLPCActor

org.agilewiki.jactor.pubsub.actorName.JActorName

org.agilewiki.jactor.pubsub.subscriber.JASubscriber

org.agilewiki.jactor.pubsub.publisher.JAPublisher

All Implemented Interfaces:

Actor, APCRequestSource, RequestProcessor, RequestSource, TargetActor, ActorName, Publisher, Subscriber

public class JAPublisher
extends JASubscriber
implements Publisher

Implements Publisher.

Nested Class Summary

Nested classes/interfaces inherited from class org.agilewiki.jactor.lpc.JLPCActor

JLPCActor.SMBuilder

Field Summary

Fields

Modifier and Type	Field and Description
protected ArrayList<Subscriber>	subscribers Table of subscribers, keyed by actor name.

Constructor Summary

Constructors

Constructor and Description
JAPublisher()

Method Summary

Methods

Modifier and Type	Method and Description
Subscriber	getSubscriber(String subscriberName) Get a subscriber.
void	publish(Request publishRequest, RP rp) Publish a request to all the appropriate subscribers.
boolean	subscribe(Subscriber subscriber) Subscribe to the publisher.
boolean	unsubscribe(Subscriber subscriber) Unsubscribe from the publisher.
void	unsubscribed(Publisher publisher, RP rp) This actor's subscription has been dropped.

Methods inherited from class org.agilewiki.jactor.pubsub.subscriber.JASubscriber

subscribed

Methods inherited from class org.agilewiki.jactor.pubsub.actorName.JActorName

getActorName, setActorName

Methods inherited from class org.agilewiki.jactor.lpc.JLPCActor

acceptEvent, acceptRequest, getActorType, getAncestor, getExceptionHandler, getFactory, getMailbox, getMailboxFactory, getMatch, getParent, hasDataItem, haveEvents, initialize, initialize, initialize, initialize, initialize, requirements, responseFrom, send, send, sendEvent, setExceptionHandler, setInitialBufferCapacity

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.agilewiki.jactor.pubsub.subscriber.Subscriber

subscribed

Methods inherited from interface org.agilewiki.jactor.pubsub.actorName.ActorName

getActorName, setActorName

Methods inherited from interface org.agilewiki.jactor.lpc.TargetActor

setExceptionHandler

Methods inherited from interface org.agilewiki.jactor.Actor

acceptEvent, acceptRequest, getActorType, getAncestor, getFactory, getMailbox, getMatch, getParent, hasDataItem, setInitialBufferCapacity

Field Detail

subscribers

protected ArrayList<Subscriber> subscribers

Table of subscribers, keyed by actor name.

Constructor Detail

JAPublisher

public JAPublisher()

Method Detail

subscribe

public boolean subscribe(Subscriber subscriber)
                  throws Exception

Subscribe to the publisher.

Specified by:

subscribe in interface Publisher

Parameters:

subscriber - The subscribing actor.

Returns:

True when a new name has been added.

Throws:

Exception

unsubscribe

public boolean unsubscribe(Subscriber subscriber)
                    throws Exception

Unsubscribe from the publisher.

Specified by:

unsubscribe in interface Publisher

Parameters:

subscriber - The subscribing actor.

Returns:

True when an actor is unsubscribed.

Throws:

Exception

getSubscriber

public Subscriber getSubscriber(String subscriberName)
                         throws Exception

Get a subscriber.

Specified by:

getSubscriber in interface Publisher

Parameters:

subscriberName - The name of the subscriber.

Returns:

The subscriber, or null.

Throws:

Exception

publish

public void publish(Request publishRequest,
           RP rp)
             throws Exception

Publish a request to all the appropriate subscribers.

Specified by:

publish in interface Publisher

Parameters:

publishRequest - The request to be published.

rp - The response processor.

Throws:

Exception

unsubscribed

public void unsubscribed(Publisher publisher,
                RP rp)
                  throws Exception

This actor's subscription has been dropped.

Specified by:

unsubscribed in interface Subscriber

Overrides:

unsubscribed in class JASubscriber

Parameters:

publisher - The publisher which has dropped the subscription.

rp - The response processor.

Throws:

Exception