com.caucho.cloud.bam

Class BamTriadSender

java.lang.Object

com.caucho.cloud.bam.BamTriadSender

public class BamTriadSender
extends java.lang.Object

Service for handling the distributed cache

Constructor Summary

Constructors

Constructor and Description
BamTriadSender(QuerySender sender, CloudPod pod, java.lang.String uid)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getAddress()
CloudPod	getPod() Returns the pod for the sender.
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.io.Serializable msg, TriadOwner owner) Sends a message to one of the triad members, including the server itself.
void	messageAll(java.io.Serializable msg) Send a message to all servers in the pod.
void	messageAllTriadRemote(java.io.Serializable msg) Send a message to active remove triad servers.
void	messageBackup(java.io.Serializable msg, TriadOwner owner)
java.lang.String	messageFirstTriad(java.io.Serializable msg, TriadOwner owner, BamTriadDispatcher.RemoteEnum remote) Sends a message to the first active remote triad server.
java.lang.String	messageFirstTriadActive(java.io.Serializable msg, TriadOwner owner) Sends a message to the first active remote triad server.
java.lang.String	messageFirstTriadRemote(java.io.Serializable msg, TriadOwner owner) Sends a message to the first active remote triad server.
void	messageTriadRemote(java.io.Serializable msg, TriadOwner owner)
void	queryAllTriadRemote(java.io.Serializable msg, QueryCallback cb) Send a message to active remove triad servers.
boolean	querySecondary(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(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(TriadOwner owner, java.io.Serializable payload, QueryCallback callback) Sends a query to the first active server in the triad.
void	queryTriadAll(TriadOwner owner, java.io.Serializable payload, QueryCallback cb, BamTriadDispatcher.RemoteEnum remote, BamTriadDispatcher.ActiveEnum active) Load a file from the remote servers.
void	queryTriadFirstActive(TriadOwner owner, java.io.Serializable payload, QueryCallback cb) Load a file from the remote servers.
java.lang.Object	queryTriadFirstRemote(TriadOwner owner, java.io.Serializable payload) Load a file from the remote servers.
java.lang.String	toString() Load a file from the remote servers.

Methods inherited from class java.lang.Object

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

Constructor Detail

BamTriadSender

public BamTriadSender(QuerySender sender,
                      CloudPod pod,
                      java.lang.String uid)

Parameters:

linkStream - stream to the broker for sending messages

pod - the owning pod

uid - the uid prefix for the generated message

Method Detail

getPod

public CloudPod getPod()

Returns the pod for the sender.

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.io.Serializable msg,
                                            TriadOwner owner)

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

messageBackup

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

messageTriadRemote

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

messageFirstTriadRemote

public java.lang.String messageFirstTriadRemote(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.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.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.io.Serializable msg)

Send a message to active remove triad servers.

queryAllTriadRemote

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

Send a message to active remove triad servers.

messageAll

public void messageAll(java.io.Serializable msg)

Send a message to all servers in the pod.

queryTriad

public boolean queryTriad(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(TriadOwner owner,
                                              java.io.Serializable payload)

Load a file from the remote servers.

queryTriadFirstActive

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

Load a file from the remote servers.

queryTriadAll

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

Load a file from the remote servers.

querySecondary

public boolean querySecondary(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(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.

toString

public java.lang.String toString()

Load a file from the remote servers.

Overrides:

toString in class java.lang.Object