Package | Description |
---|---|
com.caucho.bam.actor | |
com.caucho.bam.query | |
com.caucho.cloud.bam | |
com.caucho.distcache.cluster | |
com.caucho.hmtp | |
com.caucho.server.deploy |
Modifier and Type | Method and Description |
---|---|
void |
ActorSender.query(BamActorRef to,
java.io.Serializable payload,
QueryCallback callback)
Sends a query information call (get) to an actor,
providing a callback to receive the result or error.
|
void |
AbstractActorSender.query(BamActorRef to,
java.io.Serializable payload,
QueryCallback callback)
Sends a query information call (get) to an actor,
providing a callback to receive the result or error.
|
void |
ActorSender.query(BamActorRef to,
java.io.Serializable payload,
QueryCallback callback,
long timeout)
Sends a query information call (get) to an actor,
providing a callback to receive the result or error.
|
void |
AbstractActorSender.query(BamActorRef to,
java.io.Serializable payload,
QueryCallback callback,
long timeout)
Sends a query information call (get) to an actor,
providing a callback to receive the result or error.
|
void |
ActorProxy.query(java.io.Serializable payload,
QueryCallback callback)
Sends a query information call (get) to an actor,
providing a callback to receive the result or error.
|
void |
ActorSender.query(java.lang.String to,
java.io.Serializable payload,
QueryCallback callback)
Sends a query information call (get) to an actor,
providing a callback to receive the result or error.
|
void |
AbstractActorSender.query(java.lang.String to,
java.io.Serializable payload,
QueryCallback callback)
Sends a query information call (get) to an actor,
providing a callback to receive the result or error.
|
void |
ActorSender.query(java.lang.String to,
java.io.Serializable payload,
QueryCallback callback,
long timeout)
Sends a query information call (get) to an actor,
providing a callback to receive the result or error.
|
void |
AbstractActorSender.query(java.lang.String to,
java.io.Serializable payload,
QueryCallback callback,
long timeout)
Sends a query information call (get) to an actor,
providing a callback to receive the result or error.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractQueryCallback
callback for a query
|
class |
QueryFutureCallback
QueryFutureCallback is used to wait
for query callbacks.
|
Modifier and Type | Method and Description |
---|---|
void |
QueryManager.addQueryCallback(long id,
QueryCallback callback,
long timeout)
Adds a query callback to handle a later message.
|
void |
QueryManager.query(MessageStream stream,
java.lang.String to,
java.lang.String from,
java.io.Serializable payload,
QueryCallback cb,
long timeout)
Queries through to a stream.
|
void |
QuerySender.query(java.lang.String to,
java.io.Serializable payload,
QueryCallback callback)
Sends a query information call (get) to an actor,
providing a callback to receive the result or error.
|
void |
QuerySender.query(java.lang.String to,
java.io.Serializable payload,
QueryCallback callback,
long timeout)
Sends a query information call (get) to an actor,
providing a callback to receive the result or error.
|
Modifier and Type | Class and Description |
---|---|
class |
RouterQueryCallback
Routes a message to all members of a triad.
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterRouteManager.queryAll(java.lang.String uid,
java.io.Serializable payload,
QueryCallback cb)
Load a file from the remote servers.
|
void |
BamTriadSender.queryAllTriadRemote(java.io.Serializable msg,
QueryCallback cb)
Send a message to active remove triad servers.
|
void |
ClusterRouteManager.queryAllTriadRemote(java.lang.String uid,
java.io.Serializable msg,
QueryCallback cb)
Send a message to active remove triad servers.
|
void |
ClusterRouteManager.queryGlobalTriadFirstRemote(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload,
QueryCallback cb)
Sends a query to each 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.
|
boolean |
ClusterRouteManager.queryTriad(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload,
QueryCallback callback)
Sends a query to the first active server in the triad.
|
boolean |
BamTriadSender.queryTriad(TriadOwner owner,
java.io.Serializable payload,
QueryCallback callback)
Sends a query to the first active server in the triad.
|
void |
ClusterRouteManager.queryTriadActiveOrSelf(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload,
QueryCallback cb)
Load a file from the remote servers.
|
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.
|
void |
ClusterRouteManager.queryTriadFirstActive(java.lang.String uid,
TriadOwner owner,
java.io.Serializable payload,
QueryCallback cb)
Load a file from the remote servers.
|
void |
BamTriadSender.queryTriadFirstActive(TriadOwner owner,
java.io.Serializable payload,
QueryCallback cb)
Load a file from the remote servers.
|
Modifier and Type | Method and Description |
---|---|
void |
CacheStartupProxy.requestStartupUpdates(java.lang.String from,
long timeDelta,
QueryCallback cb) |
Modifier and Type | Method and Description |
---|---|
void |
HmtpClient.query(BamActorRef to,
java.io.Serializable payload,
QueryCallback callback) |
void |
HmtpClient.query(BamActorRef to,
java.io.Serializable payload,
QueryCallback callback,
long timeout) |
void |
HmtpClient.query(java.lang.String to,
java.io.Serializable payload,
QueryCallback callback) |
void |
HmtpClient.query(java.lang.String to,
java.io.Serializable payload,
QueryCallback callback,
long timeout) |
Modifier and Type | Method and Description |
---|---|
void |
DeployActorProxy.sendFile(java.lang.String sha1,
StreamSource source,
QueryCallback callback) |