org.agilewiki.jactor.pubsub.publisher

Class Publish

java.lang.Object

org.agilewiki.jactor.lpc.Request<Integer,Publisher>

org.agilewiki.jactor.pubsub.publisher.Publish

public class Publish
extends Request<Integer,Publisher>

Broadcast a request to all applicable subscribers. The response is the number of subscribers to which the request was broadcast.

Field Summary

Fields

Modifier and Type	Field and Description
Request	publishRequest The request to be published.

Constructor Summary

Constructors

Constructor and Description
Publish(Request publishRequest) Create a Publish request.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isTargetType(Actor targetActor) Returns true when targetActor is an instanceof TARGET_TYPE
void	processRequest(JLPCActor targetActor, RP rp)

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

getTargetActor, send, send, send, send, sendEvent, sendEvent, sendEvent, sendEvent

Methods inherited from class java.lang.Object

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

Field Detail

publishRequest

public final Request publishRequest

The request to be published.

Constructor Detail

Publish

public Publish(Request publishRequest)

Create a Publish request.

Parameters:

publishRequest - The request to be published.

Method Detail

isTargetType

public boolean isTargetType(Actor targetActor)

Returns true when targetActor is an instanceof TARGET_TYPE

Specified by:

isTargetType in class Request<Integer,Publisher>

Parameters:

targetActor - The actor to be called.

Returns:

True when targetActor is an instanceof TARGET_TYPE.

processRequest

public void processRequest(JLPCActor targetActor,
                  RP rp)
                    throws Exception

Specified by:

processRequest in class Request<Integer,Publisher>

Throws:

Exception