Package | Description |
---|---|
com.caucho.amp | |
com.caucho.amp.actor | |
com.caucho.amp.broker | |
com.caucho.amp.impl | |
com.caucho.amp.router | |
com.caucho.amp.skeleton | |
com.caucho.amp.stream |
Modifier and Type | Method and Description |
---|---|
AmpActorRef |
AmpManager.addActor(java.lang.String address,
AmpActor actor)
Adds an actor stream, creating the mailbox for it
using the default factory.
|
AmpActorRef |
AmpManager.addActor(java.lang.String address,
java.lang.Object bean)
Adds a bean to be proxied as an actor.
|
Modifier and Type | Method and Description |
---|---|
<T> T |
AmpManager.createActorProxy(AmpActorRef actorRef,
java.lang.Class<T> api)
Creates a client proxy to an api.
|
void |
AmpQueryCallback.onQueryError(AmpActorRef to,
AmpActorRef from,
AmpError error) |
void |
AmpQueryCallback.onQueryResult(AmpActorRef to,
AmpActorRef from,
java.lang.Object result) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractActorRef
Sender for an actor ref.
|
class |
ActorRefImpl
Handles the context for an actor, primarily including its
query map.
|
class |
NullActorRef
Sender for an actor ref.
|
Modifier and Type | Method and Description |
---|---|
AmpActorRef |
ActorContextImpl.getActorRef() |
abstract AmpActorRef |
AmpActorContext.getActorRef() |
Modifier and Type | Method and Description |
---|---|
void |
ActorContextImpl.error(AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
AmpProxyActor.error(AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
AmpActorRef.error(AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
AbstractActorRef.error(AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
NullActorRef.error(AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
ActorRefImpl.error(AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
AmpQueryFuture.onQueryError(AmpActorRef to,
AmpActorRef from,
AmpError error) |
void |
AmpQueryFuture.onQueryResult(AmpActorRef to,
AmpActorRef from,
java.lang.Object result) |
void |
ActorContextImpl.query(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
AmpProxyActor.query(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
AmpActorRef.query(long id,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
AbstractActorRef.query(long id,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
NullActorRef.query(long id,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
ActorRefImpl.query(long id,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
AmpMethodRef.query(long id,
AmpActorRef from,
java.lang.Object... args) |
void |
ActorContextImpl.queryError(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
AmpProxyActor.queryError(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
AmpActorRef.queryError(long id,
AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
AbstractActorRef.queryError(long id,
AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
NullActorRef.queryError(long id,
AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
ActorRefImpl.queryError(long id,
AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
ActorContextImpl.queryResult(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.Object result) |
void |
AmpProxyActor.queryResult(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.Object result) |
void |
AmpActorRef.reply(long id,
AmpActorRef from,
AmpEncoder encoder,
java.lang.Object result) |
void |
AbstractActorRef.reply(long id,
AmpActorRef from,
AmpEncoder encoder,
java.lang.Object result) |
void |
NullActorRef.reply(long id,
AmpActorRef from,
AmpEncoder encoder,
java.lang.Object result) |
void |
ActorRefImpl.reply(long id,
AmpActorRef from,
AmpEncoder encoder,
java.lang.Object result) |
void |
ActorContextImpl.send(AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
AmpProxyActor.send(AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
AmpActorRef.send(AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
AbstractActorRef.send(AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
NullActorRef.send(AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
ActorRefImpl.send(AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
AmpMethodRef.send(AmpActorRef from,
java.lang.Object... args) |
Modifier and Type | Method and Description |
---|---|
AmpActorRef |
AbstractAmpBroker.addMailbox(java.lang.String address,
AmpMailbox mailbox) |
AmpActorRef |
AmpBroker.addMailbox(java.lang.String address,
AmpMailbox mailbox)
Adds a mailbox (optional operation).
|
AmpActorRef |
AbstractAmpBroker.getActorRef(java.lang.String to) |
AmpActorRef |
AmpBroker.getActorRef(java.lang.String address)
Returns a mailbox for the given address,
or null if the mailbox does not exist.
|
AmpActorRef |
AbstractAmpBroker.getBrokerActor() |
AmpActorRef |
AmpBroker.getBrokerActor()
Returns the mailbox to the router itself.
|
Modifier and Type | Method and Description |
---|---|
AmpActorRef |
AmpManagerImpl.addActor(java.lang.String address,
AmpActor actor) |
AmpActorRef |
AmpManagerImpl.addActor(java.lang.String address,
java.lang.Object bean) |
AmpActorRef |
HashMapAmpBroker.addMailbox(java.lang.String address,
AmpMailbox mailbox) |
AmpActorRef |
HashMapAmpBroker.getActorRef(java.lang.String address) |
Modifier and Type | Method and Description |
---|---|
<T> T |
AmpManagerImpl.createActorProxy(AmpActorRef to,
java.lang.Class<T> api) |
void |
SimpleAmpMailbox.error(AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
QueueMailbox.error(AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
SimpleAmpMailbox.query(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
QueueMailbox.query(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
SimpleAmpMailbox.queryError(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
QueueMailbox.queryError(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
SimpleAmpMailbox.queryResult(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.Object result) |
void |
QueueMailbox.queryResult(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.Object result) |
void |
SimpleAmpMailbox.send(AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
QueueMailbox.send(AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
Modifier and Type | Class and Description |
---|---|
class |
FirstActorRouter
Sender for an actor ref.
|
Constructor and Description |
---|
FirstActorRouter(AmpManager manager,
AmpActorRef... actors) |
Modifier and Type | Method and Description |
---|---|
<T> T |
AmpReflectionSkeletonFactory.createStub(java.lang.Class<T> api,
AmpActorRef to,
AmpActorContext systemContext) |
<T> T |
AmpSkeletonFactory.createStub(java.lang.Class<T> api,
AmpActorRef to,
AmpActorContext systemContext) |
Modifier and Type | Method and Description |
---|---|
void |
AmpStream.error(AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
AmpError error)
Sends a message error to an
ActorHolder ,
addressed by the Actor's address. |
void |
AbstractAmpStream.error(AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
AmpStream.query(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args)
Sends a query/RPCinformation call
The receiver of a
query acts as a service and the
caller acts as a client. |
void |
AbstractAmpStream.query(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |
void |
AmpStream.queryError(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
AmpError error)
Sends a query error from a failed query.
|
void |
AbstractAmpStream.queryError(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
AmpError error) |
void |
AmpStream.queryResult(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.Object result)
Sends a query response for a query
|
void |
AbstractAmpStream.queryResult(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.Object result) |
void |
AmpStream.send(AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args)
Sends a unidirectional message to an
ActorHolder ,
addressed by the Actor's address. |
void |
AbstractAmpStream.send(AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args) |