Package | Description |
---|---|
com.caucho.bam.actor | |
com.caucho.bam.manager | |
com.caucho.bam.proxy | |
com.caucho.bam.router | |
com.caucho.cloud.bam | |
com.caucho.hmtp |
Modifier and Type | Class and Description |
---|---|
class |
SimpleActorRef
Abstract implementation of a BAM actor.
|
Modifier and Type | Method and Description |
---|---|
void |
ActorSender.message(BamActorRef to,
java.io.Serializable payload)
Sends a unidirectional message to an
ActorHolder ,
addressed by the Actor's address. |
void |
AbstractActorSender.message(BamActorRef to,
java.io.Serializable payload)
Sends a unidirectional message to an
ActorHolder ,
addressed by the Actor's address. |
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.
|
Modifier and Type | Method and Description |
---|---|
BamActorRef |
SimpleBamManager.createActorRef(java.lang.String to) |
BamActorRef |
BamManager.createActorRef(java.lang.String to) |
Modifier and Type | Method and Description |
---|---|
<T> T |
SimpleBamManager.createProxy(java.lang.Class<T> api,
BamActorRef to,
ActorSender sender) |
<T> T |
BamManager.createProxy(java.lang.Class<T> api,
BamActorRef to,
ActorSender sender) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
BamProxyFactory.createProxy(java.lang.Class<T> api,
BamActorRef to,
ActorSender sender,
long timeout) |
Modifier and Type | Interface and Description |
---|---|
interface |
BamRouter
Sends a message to the first available actor.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractBamRouter
Sends a message to the first available actor.
|
class |
BamAllActorRouter
Sends a message to the first available actor.
|
class |
BamFirstActorRouter
Sends a message to the first available actor.
|
class |
BamFirstResultRouter
Sends a message to the first available actor.
|
Modifier and Type | Method and Description |
---|---|
protected BamActorRef[] |
BamFirstActorRouter.getActors() |
protected BamActorRef[] |
BamAllActorRouter.getActors() |
protected BamActorRef[] |
BamFirstResultRouter.getActors() |
Constructor and Description |
---|
BamAllActorRouter(ActorSender sender,
boolean isForce,
BamActorRef... actors) |
BamFirstActorRouter(ActorSender sender,
long timeout,
BamActorRef... actors) |
BamFirstResultRouter(ActorSender sender,
long timeout,
BamActorRef... actors) |
Modifier and Type | Class and Description |
---|---|
class |
CloudServerActorRef
Abstract implementation of a BAM actor.
|
class |
CloudServerNullActorRef
A BAM actor where the server is unreachable.
|
class |
CloudServerRemoteActorRef
Abstract implementation of a BAM actor.
|
class |
PodAllRemoteRouter
Routes a message to all members of a triad.
|
class |
PodAllRouter
Routes a message to all members of a triad.
|
Modifier and Type | Method and Description |
---|---|
protected BamActorRef |
PodAllRemoteRouter.createActor(java.lang.String uid,
ClusterServer server) |
protected BamActorRef |
PodAllRouter.createActor(java.lang.String uid,
ClusterServer server) |
protected BamActorRef[] |
PodAllRouter.getActors() |
Modifier and Type | Method and Description |
---|---|
void |
HmtpClient.message(BamActorRef to,
java.io.Serializable payload) |
void |
HmtpClient.query(BamActorRef to,
java.io.Serializable payload,
QueryCallback callback) |
void |
HmtpClient.query(BamActorRef to,
java.io.Serializable payload,
QueryCallback callback,
long timeout) |