com.caucho.cloud.bam

Class TriadAllRouter

java.lang.Object

com.caucho.bam.stream.AbstractMessageStream

com.caucho.cloud.bam.TriadAllRouter

All Implemented Interfaces:

MessageStream

public class TriadAllRouter
extends AbstractMessageStream

Routes a message to all members of a triad.

Constructor Summary

Constructors

Constructor and Description
TriadAllRouter(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

Constructor Detail

TriadAllRouter

public TriadAllRouter(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