com.caucho.cloud.bam

Class ClusterRouteManager

java.lang.Object

com.caucho.cloud.topology.AbstractCloudServerListener

com.caucho.cloud.bam.ClusterRouteManager

All Implemented Interfaces:

CloudServerListener

public class ClusterRouteManager
extends AbstractCloudServerListener

Service for handling the distributed cache

Constructor Summary

Constructors

Constructor and Description
ClusterRouteManager(ActorSender sender, CloudPod pod)

Method Summary

Modifier and Type	Method and Description
static ClusterRouteManager	create(CloudPod pod)
java.lang.String	getAddress()
java.lang.String	getPrimaryAddress(TriadOwner owner)
java.lang.String	getSecondaryAddress(TriadOwner owner)
java.lang.String	getTertiaryAddress(TriadOwner owner)
boolean	isPrimarySelf(TriadOwner owner)
java.lang.String	messageActiveOrSelf(java.lang.String uid, java.io.Serializable msg, TriadOwner owner) Sends a message to one of the triad members, including the server itself.
void	messageAll(java.lang.String uid, java.io.Serializable msg) Send a message to all servers in the pod.
void	messageAllTriadRemote(java.lang.String uid, java.io.Serializable msg) Send a message to active remove triad servers.
void	messageBackup(java.lang.String uid, java.io.Serializable msg, TriadOwner owner)
java.lang.String	messageFirstTriad(java.lang.String uid, java.io.Serializable msg, TriadOwner owner, BamTriadDispatcher.RemoteEnum remote) Sends a message to the first active remote triad server.
java.lang.String	messageFirstTriadActive(java.lang.String uid, java.io.Serializable msg, TriadOwner owner) Sends a message to the first active remote triad server.
java.lang.String	messageFirstTriadRemote(java.lang.String uid, java.io.Serializable msg, TriadOwner owner) Sends a message to the first active remote triad server.
void	messageTriadRemote(java.lang.String uid, java.io.Serializable msg, TriadOwner owner)
void	queryAll(java.lang.String uid, java.io.Serializable payload, QueryCallback cb) Load a file from the remote servers.
void	queryAllTriadRemote(java.lang.String uid, java.io.Serializable msg, QueryCallback cb) Send a message to active remove triad servers.
void	queryGlobalTriadFirstRemote(java.lang.String uid, TriadOwner owner, java.io.Serializable payload, QueryCallback cb) Sends a query to each server.
boolean	queryPrimary(java.lang.String uid, TriadOwner owner, java.io.Serializable payload, QueryCallback callback, BamTriadDispatcher.RemoteEnum remote, BamTriadDispatcher.ActiveEnum active) Query the primary server, returning true if the query was sent or false if the server doesn't exist or doesn't match the predicates.
boolean	querySecondary(java.lang.String uid, TriadOwner owner, java.io.Serializable payload, QueryCallback callback, BamTriadDispatcher.RemoteEnum remote, BamTriadDispatcher.ActiveEnum active) Query the primary server, returning true if the query was sent or false if the server doesn't exist or doesn't match the predicates.
boolean	queryTertiary(java.lang.String uid, TriadOwner owner, java.io.Serializable payload, QueryCallback callback, BamTriadDispatcher.RemoteEnum remote, BamTriadDispatcher.ActiveEnum active) Query the primary server, returning true if the query was sent or false if the server doesn't exist or doesn't match the predicates.
boolean	queryTriad(java.lang.String uid, TriadOwner owner, java.io.Serializable payload, QueryCallback callback) Sends a query to the first active server in the triad.
java.lang.Object	queryTriadActiveOrSelf(java.lang.String uid, TriadOwner owner, java.io.Serializable payload) Load a file from the remote servers.
void	queryTriadActiveOrSelf(java.lang.String uid, TriadOwner owner, java.io.Serializable payload, QueryCallback cb) Load a file from the remote servers.
void	queryTriadAll(java.lang.String uid, TriadOwner owner, java.io.Serializable payload, QueryCallback cb, BamTriadDispatcher.RemoteEnum remote, BamTriadDispatcher.ActiveEnum active) Load a file from the remote servers.
void	queryTriadFirst(java.lang.String uid, TriadOwner owner, java.io.Serializable payload, QueryCallback cb, BamTriadDispatcher.RemoteEnum isRemote) Load a file from the remote servers.
void	queryTriadFirstActive(java.lang.String uid, TriadOwner owner, java.io.Serializable payload, QueryCallback cb) Load a file from the remote servers.
java.lang.Object	queryTriadFirstRemote(java.lang.String uid, TriadOwner owner, java.io.Serializable payload) Load a file from the remote servers.
java.lang.String	toString()

Methods inherited from class com.caucho.cloud.topology.AbstractCloudServerListener

onServerAdd, onServerRemove, onServerStateChange, onTriadAdd, onTriadRemove

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterRouteManager

public ClusterRouteManager(ActorSender sender,
                           CloudPod pod)

Parameters:

sender - the outgoing query sender for the router

pod - the owning pod

Method Detail

create

public static ClusterRouteManager create(CloudPod pod)

getAddress

public java.lang.String getAddress()

isPrimarySelf

public boolean isPrimarySelf(TriadOwner owner)

getPrimaryAddress

public java.lang.String getPrimaryAddress(TriadOwner owner)

getSecondaryAddress

public java.lang.String getSecondaryAddress(TriadOwner owner)

getTertiaryAddress

public java.lang.String getTertiaryAddress(TriadOwner owner)

messageActiveOrSelf

public java.lang.String messageActiveOrSelf(java.lang.String uid,
                                            java.io.Serializable msg,
                                            TriadOwner owner)

Sends a message to one of the triad members, including the server itself.

messageBackup

public void messageBackup(java.lang.String uid,
                          java.io.Serializable msg,
                          TriadOwner owner)

messageTriadRemote

public void messageTriadRemote(java.lang.String uid,
                               java.io.Serializable msg,
                               TriadOwner owner)

messageFirstTriadRemote

public java.lang.String messageFirstTriadRemote(java.lang.String uid,
                                                java.io.Serializable msg,
                                                TriadOwner owner)

Sends a message to the first active remote triad server. For a triad server, this will not send a message to itself. Used by triad servers to send backup data or for services that send a copy to the triad.

messageFirstTriadActive

public java.lang.String messageFirstTriadActive(java.lang.String uid,
                                                java.io.Serializable msg,
                                                TriadOwner owner)

Sends a message to the first active remote triad server. For a triad server, this will not send a message to itself. Used by triad servers to send backup data or for services that send a copy to the triad.

messageFirstTriad

public java.lang.String messageFirstTriad(java.lang.String uid,
                                          java.io.Serializable msg,
                                          TriadOwner owner,
                                          BamTriadDispatcher.RemoteEnum remote)

Sends a message to the first active remote triad server. For a triad server, this will not send a message to itself. Used by triad servers to send backup data or for services that send a copy to the triad.

messageAllTriadRemote

public void messageAllTriadRemote(java.lang.String uid,
                                  java.io.Serializable msg)

Send a message to active remove triad servers.

queryAllTriadRemote

public void queryAllTriadRemote(java.lang.String uid,
                                java.io.Serializable msg,
                                QueryCallback cb)

Send a message to active remove triad servers.

messageAll

public void messageAll(java.lang.String uid,
                       java.io.Serializable msg)

Send a message to all servers in the pod.

queryTriad

public boolean queryTriad(java.lang.String uid,
                          TriadOwner owner,
                          java.io.Serializable payload,
                          QueryCallback callback)

Sends a query to the first active server in the triad.

queryTriadFirstRemote

public java.lang.Object queryTriadFirstRemote(java.lang.String uid,
                                              TriadOwner owner,
                                              java.io.Serializable payload)

Load a file from the remote servers.

queryGlobalTriadFirstRemote

public void queryGlobalTriadFirstRemote(java.lang.String uid,
                                        TriadOwner owner,
                                        java.io.Serializable payload,
                                        QueryCallback cb)

Sends a query to each server.

queryTriadFirst

public void queryTriadFirst(java.lang.String uid,
                            TriadOwner owner,
                            java.io.Serializable payload,
                            QueryCallback cb,
                            BamTriadDispatcher.RemoteEnum isRemote)

Load a file from the remote servers.

queryTriadFirstActive

public void queryTriadFirstActive(java.lang.String uid,
                                  TriadOwner owner,
                                  java.io.Serializable payload,
                                  QueryCallback cb)

Load a file from the remote servers.

queryAll

public void queryAll(java.lang.String uid,
                     java.io.Serializable payload,
                     QueryCallback cb)

Load a file from the remote servers.

queryTriadAll

public void queryTriadAll(java.lang.String uid,
                          TriadOwner owner,
                          java.io.Serializable payload,
                          QueryCallback cb,
                          BamTriadDispatcher.RemoteEnum remote,
                          BamTriadDispatcher.ActiveEnum active)

Load a file from the remote servers.

queryPrimary

public boolean queryPrimary(java.lang.String uid,
                            TriadOwner owner,
                            java.io.Serializable payload,
                            QueryCallback callback,
                            BamTriadDispatcher.RemoteEnum remote,
                            BamTriadDispatcher.ActiveEnum active)

Query the primary server, returning true if the query was sent or false if the server doesn't exist or doesn't match the predicates.

querySecondary

public boolean querySecondary(java.lang.String uid,
                              TriadOwner owner,
                              java.io.Serializable payload,
                              QueryCallback callback,
                              BamTriadDispatcher.RemoteEnum remote,
                              BamTriadDispatcher.ActiveEnum active)

Query the primary server, returning true if the query was sent or false if the server doesn't exist or doesn't match the predicates.

queryTertiary

public boolean queryTertiary(java.lang.String uid,
                             TriadOwner owner,
                             java.io.Serializable payload,
                             QueryCallback callback,
                             BamTriadDispatcher.RemoteEnum remote,
                             BamTriadDispatcher.ActiveEnum active)

Query the primary server, returning true if the query was sent or false if the server doesn't exist or doesn't match the predicates.

queryTriadActiveOrSelf

public java.lang.Object queryTriadActiveOrSelf(java.lang.String uid,
                                               TriadOwner owner,
                                               java.io.Serializable payload)

Load a file from the remote servers.

queryTriadActiveOrSelf

public void queryTriadActiveOrSelf(java.lang.String uid,
                                   TriadOwner owner,
                                   java.io.Serializable payload,
                                   QueryCallback cb)

Load a file from the remote servers.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object