|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.caucho.amp.actor.AmpProxyActor
public final class AmpProxyActor
Handles the context for an actor, primarily including its query map.
Constructor Summary | |
---|---|
AmpProxyActor(java.lang.String address,
AmpMailboxBuilder mailboxFactory)
|
Method Summary | |
---|---|
void |
error(AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
AmpError error)
Sends a message error to an ActorHolder ,
addressed by the Actor's address. |
ActorContextImpl |
getActorContext()
|
AmpMethodRef |
getMethod(java.lang.String methodName,
AmpEncoder encoder)
|
void |
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 |
queryError(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
AmpError error)
Sends a query error from a failed query. |
void |
queryResult(long id,
AmpActorRef to,
AmpActorRef from,
AmpEncoder encoder,
java.lang.Object result)
Sends a query response for a query |
void |
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. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AmpProxyActor(java.lang.String address, AmpMailboxBuilder mailboxFactory)
Method Detail |
---|
public ActorContextImpl getActorContext()
public void send(AmpActorRef to, AmpActorRef from, AmpEncoder encoder, java.lang.String methodName, java.lang.Object... args)
AmpStream
ActorHolder
,
addressed by the Actor's address.
send
in interface AmpStream
to
- the target actor's addressfrom
- the source actor's addresspublic void error(AmpActorRef to, AmpActorRef from, AmpEncoder encoder, AmpError error)
AmpStream
ActorHolder
,
addressed by the Actor's address. Actor protocols may choose to send
error messages if a message fails for some reason.
In general, Actors should not rely on the delivery of error messages.
If an error return is required, use an RPC query instead.
error
in interface AmpStream
to
- the target actor's addressfrom
- the source actor's addresserror
- the message errorpublic void query(long id, AmpActorRef to, AmpActorRef from, AmpEncoder encoder, java.lang.String methodName, java.lang.Object... args)
AmpStream
query
acts as a service and the
caller acts as a client. Because BAM Actors are symmetrical, all
Actors can act as services and clients for different RPC calls.
The stream MUST send a queryResult
or
queryError
to the client using the same id
,
because RPC clients rely on a response.
query
in interface AmpStream
id
- the query identifier used to match requests with responsesto
- the service actor's addressfrom
- the client actor's addresspublic void queryResult(long id, AmpActorRef to, AmpActorRef from, AmpEncoder encoder, java.lang.Object result)
AmpStream
queryResult
in interface AmpStream
id
- the query identifier used to match requests with responsesto
- the client actor's addressfrom
- the service actor's addresspublic void queryError(long id, AmpActorRef to, AmpActorRef from, AmpEncoder encoder, AmpError error)
AmpStream
queryError
in interface AmpStream
id
- the query identifier used to match requests with responsesto
- the client actor's addressfrom
- the service actor's addresserror
- additional error informationpublic AmpMethodRef getMethod(java.lang.String methodName, AmpEncoder encoder)
getMethod
in interface AmpActor
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |