com.caucho.cloud.bam

Class BamTriadDispatcher

java.lang.Object

com.caucho.cloud.topology.AbstractCloudServerListener

com.caucho.cloud.bam.BamTriadDispatcher

All Implemented Interfaces:

CloudServerListener

public final class BamTriadDispatcher
extends AbstractCloudServerListener

Service for handling the distributed cache

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BamTriadDispatcher.ActiveEnum
static class	BamTriadDispatcher.RemoteEnum

Constructor Summary

Constructors

Constructor and Description
BamTriadDispatcher(CloudPod pod)

Method Summary

Modifier and Type	Method and Description
static BamTriadDispatcher	create(CloudPod pod)
com.caucho.cloud.bam.BamTriadDispatcher.BamServer	getA()
java.lang.String	getActiveAddress(TriadOwner owner) Returns the address of the first active server.
java.lang.String	getActiveAddress(TriadOwner owner, java.lang.String oldAddress) Returns the address of the first active backup server.
java.lang.String	getActiveOrSelfAddress(TriadOwner owner) Returns the address of the first active server.
ClusterServer	getActiveOrSelfServer(TriadOwner owner) Returns the address of the first active server.
com.caucho.cloud.bam.BamTriadDispatcher.BamServer	getB()
com.caucho.cloud.bam.BamTriadDispatcher.BamServer	getC()
CloudPod	getPod() Returns the pod for the sender.
java.lang.String	getPrimaryActiveAddress(TriadOwner owner) Returns the address of the primary, or null if the server doesn't exist.
java.lang.String	getPrimaryAddress(TriadOwner owner) Returns the address of the primary, or null if the server doesn't exist.
java.lang.String	getSecondaryActiveAddress(TriadOwner owner) Returns the address of the secondary, or null if the server doesn't exist.
java.lang.String	getSecondaryAddress(TriadOwner owner) Returns the address of the secondary, or null if the server doesn't exist.
java.lang.String	getTertiaryActiveAddress(TriadOwner owner) Returns the address of the tertiary, or null if the server doesn't exist.
java.lang.String	getTertiaryAddress(TriadOwner owner) Returns the address of the tertiary, or null if the server doesn't exist.
boolean	isPrimarySelf(TriadOwner owner) Returns the address of the primary, or null if the server doesn't exist.
void	onTriadAdd(TriadServer server)
void	onTriadRemove(TriadServer server)
com.caucho.cloud.bam.BamTriadDispatcher.BamServer	primary(TriadOwner owner)
boolean	queryPrimary(java.lang.String uid, TriadOwner owner, QuerySender sender, 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, QuerySender sender, 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, QuerySender sender, 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.
com.caucho.cloud.bam.BamTriadDispatcher.BamServer	secondary(TriadOwner owner)
com.caucho.cloud.bam.BamTriadDispatcher.BamServer	tertiary(TriadOwner owner)
java.lang.String	toString()

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

onServerAdd, onServerRemove, onServerStateChange

Methods inherited from class java.lang.Object

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

Constructor Detail

BamTriadDispatcher

public BamTriadDispatcher(CloudPod pod)

Parameters:

linkStream - stream to the broker for sending messages

pod - the owning pod

uid - the uid prefix for the generated message

Method Detail

create

public static BamTriadDispatcher create(CloudPod pod)

getPod

public CloudPod getPod()

Returns the pod for the sender.

getA

public com.caucho.cloud.bam.BamTriadDispatcher.BamServer getA()

getB

public com.caucho.cloud.bam.BamTriadDispatcher.BamServer getB()

getC

public com.caucho.cloud.bam.BamTriadDispatcher.BamServer getC()

primary

public com.caucho.cloud.bam.BamTriadDispatcher.BamServer primary(TriadOwner owner)

secondary

public com.caucho.cloud.bam.BamTriadDispatcher.BamServer secondary(TriadOwner owner)

tertiary

public com.caucho.cloud.bam.BamTriadDispatcher.BamServer tertiary(TriadOwner owner)

isPrimarySelf

public boolean isPrimarySelf(TriadOwner owner)

Returns the address of the primary, or null if the server doesn't exist.

getPrimaryAddress

public java.lang.String getPrimaryAddress(TriadOwner owner)

Returns the address of the primary, or null if the server doesn't exist.

getSecondaryAddress

public java.lang.String getSecondaryAddress(TriadOwner owner)

Returns the address of the secondary, or null if the server doesn't exist.

getTertiaryAddress

public java.lang.String getTertiaryAddress(TriadOwner owner)

Returns the address of the tertiary, or null if the server doesn't exist.

getPrimaryActiveAddress

public java.lang.String getPrimaryActiveAddress(TriadOwner owner)

Returns the address of the primary, or null if the server doesn't exist.

getSecondaryActiveAddress

public java.lang.String getSecondaryActiveAddress(TriadOwner owner)

Returns the address of the secondary, or null if the server doesn't exist.

getTertiaryActiveAddress

public java.lang.String getTertiaryActiveAddress(TriadOwner owner)

Returns the address of the tertiary, or null if the server doesn't exist.

getActiveAddress

public java.lang.String getActiveAddress(TriadOwner owner)

Returns the address of the first active server.

getActiveOrSelfAddress

public java.lang.String getActiveOrSelfAddress(TriadOwner owner)

Returns the address of the first active server.

getActiveAddress

public java.lang.String getActiveAddress(TriadOwner owner,
                                         java.lang.String oldAddress)

Returns the address of the first active backup server.

getActiveOrSelfServer

public ClusterServer getActiveOrSelfServer(TriadOwner owner)

Returns the address of the first active server.

queryPrimary

public boolean queryPrimary(java.lang.String uid,
                            TriadOwner owner,
                            QuerySender sender,
                            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,
                              QuerySender sender,
                              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,
                             QuerySender sender,
                             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.

onTriadAdd

public void onTriadAdd(TriadServer server)

Specified by:

onTriadAdd in interface CloudServerListener

Overrides:

onTriadAdd in class AbstractCloudServerListener

onTriadRemove

public void onTriadRemove(TriadServer server)

Specified by:

onTriadRemove in interface CloudServerListener

Overrides:

onTriadRemove in class AbstractCloudServerListener

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object