|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.caucho.amp.stream.AbstractAmpStream
public class AbstractAmpStream
Primary stream handling all message packets.
Actors
send packets to the
Broker
for delivery to other Actors.
Messages are divided into two groups:
Constructor Summary | |
---|---|
AbstractAmpStream()
|
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. |
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 AbstractAmpStream()
Method Detail |
---|
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 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 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 error
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |