Package | Description |
---|---|
com.caucho.cloud.bam |
Modifier and Type | Method and Description |
---|---|
static BamTriadDispatcher.RemoteEnum |
BamTriadDispatcher.RemoteEnum.valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static BamTriadDispatcher.RemoteEnum[] |
BamTriadDispatcher.RemoteEnum.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
<T> T |
BamCloudManager.createTriadFirstProxy(java.lang.Class<T> api,
java.lang.String uid,
CloudPod pod,
TriadOwner owner,
BamTriadDispatcher.RemoteEnum isRemote,
BamCloudManager.ResultEnum isResult,
long timeout) |
<T> T |
BamCloudManager.createTriadFirstProxy(java.lang.Class<T> api,
java.lang.String uid,
TriadOwner owner,
BamTriadDispatcher.RemoteEnum isRemote,
BamCloudManager.ResultEnum isResult,
long timeout) |
<T> com.caucho.cloud.bam.BamCloudManager.TriadFirstShard<T> |
BamCloudManager.createTriadFirstProxyArray(java.lang.Class<T> api,
java.lang.String uid,
BamTriadDispatcher.RemoteEnum isRemote,
BamCloudManager.ResultEnum isResult,
long timeout) |
<T> com.caucho.cloud.bam.BamCloudManager.TriadFirstShard<T> |
BamCloudManager.createTriadFirstProxyArray(java.lang.Class<T> api,
java.lang.String uid,
CloudPod pod,
BamTriadDispatcher.RemoteEnum isRemote,
BamCloudManager.ResultEnum isResult,
long timeout) |
java.lang.String |
BamTriadSender.messageFirstTriad(java.io.Serializable msg,
TriadOwner owner,
BamTriadDispatcher.RemoteEnum remote)
Sends a message to the first active remote triad server.
|
java.lang.String |
ClusterRouteManager.messageFirstTriad(java.lang.String uid,
java.io.Serializable msg,
TriadOwner owner,
BamTriadDispatcher.RemoteEnum remote)
Sends a message to the first active remote triad server.
|
boolean |
BamTriadDispatcher.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 |
ClusterRouteManager.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 |
BamTriadDispatcher.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 |
ClusterRouteManager.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 |
BamTriadSender.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 |
BamTriadDispatcher.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.
|
boolean |
ClusterRouteManager.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 |
BamTriadSender.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.
|
void |
ClusterRouteManager.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 |
BamTriadSender.queryTriadAll(TriadOwner owner,
java.io.Serializable payload,
QueryCallback cb,
BamTriadDispatcher.RemoteEnum remote,
BamTriadDispatcher.ActiveEnum active)
Load a file from the remote servers.
|
void |
ClusterRouteManager.queryTriadFirst(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload,
QueryCallback cb,
BamTriadDispatcher.RemoteEnum isRemote)
Load a file from the remote servers.
|
Constructor and Description |
---|
TriadFirstRouter(java.lang.String uid,
ClusterRouteManager routeManager,
TriadOwner owner,
Broker broker,
BamTriadDispatcher.RemoteEnum isRemote) |