| 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) |