com.caucho.cloud.bam

Class GlobalTriadFirstRouter

java.lang.Object

com.caucho.bam.stream.AbstractMessageStream

com.caucho.bam.actor.AbstractActor

com.caucho.cloud.bam.GlobalTriadFirstRouter

All Implemented Interfaces:

Actor, MessageStream

public class GlobalTriadFirstRouter
extends AbstractActor

Routes a message to all pods in the system,

Constructor Summary

Constructors

Constructor and Description
GlobalTriadFirstRouter(java.lang.String uid, ClusterRouteManager routeManager, TriadOwner owner, Broker broker)

Method Summary

Modifier and Type	Method and Description
void	message(java.lang.String to, java.lang.String from, java.io.Serializable payload) Receives a unidirectional message.
void	query(long id, java.lang.String to, java.lang.String from, java.io.Serializable payload) Receives a query call, acting as a service for the query.

Methods inherited from class com.caucho.bam.stream.AbstractMessageStream

getAddress, getBroker, isClosed, messageError, queryError, queryResult, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.caucho.bam.stream.MessageStream

getAddress, getBroker, isClosed, messageError, queryError, queryResult

Constructor Detail

GlobalTriadFirstRouter

public GlobalTriadFirstRouter(java.lang.String uid,
                              ClusterRouteManager routeManager,
                              TriadOwner owner,
                              Broker broker)

Method Detail

message

public void message(java.lang.String to,
                    java.lang.String from,
                    java.io.Serializable payload)

Description copied from class: AbstractMessageStream

Receives a unidirectional message. The abstract implementation ignores the message.

Specified by:

message in interface MessageStream

Overrides:

message in class AbstractMessageStream

Parameters:

to - the target actor's address

from - the source actor's address

payload - the message payload

query

public void query(long id,
                  java.lang.String to,
                  java.lang.String from,
                  java.io.Serializable payload)

Description copied from class: AbstractMessageStream

Receives a query call, acting as a service for the query. The default implementation returns a feature-not-implemented QueryError message to the client.

Specified by:

query in interface MessageStream

Overrides:

query in class AbstractMessageStream

Parameters:

id - the query identifier used to match requests with responses

to - the service actor's address

from - the client actor's address

payload - the query payload