public interface ActorProxy
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the proxy
|
MessageStream |
getActorStream()
Returns the stream to this client.
|
java.lang.String |
getAddress()
Returns the proxy's address used for all "from" parameters.
|
MessageStream |
getClientStream()
Returns the registered callback
MessageStream . |
MessageStream |
getLinkStream()
The ActorStream to the link.
|
java.lang.String |
getTo()
Returns the target actor's address used for all "to" parameters.
|
boolean |
isClosed()
Returns true if the proxy is closed
|
void |
message(java.io.Serializable payload)
Sends a unidirectional message to the target
ActorHolder , |
java.io.Serializable |
query(java.io.Serializable payload)
Sends a query information call (get) to an actor,
blocking until the actor responds with a result or an error.
|
java.io.Serializable |
query(java.io.Serializable payload,
long timeout)
Sends a query information call (get) to an actor,
blocking until the actor responds with a result or an error.
|
void |
query(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 |
setClientStream(MessageStream clientStream)
Registers a callback
MessageStream with the client |
void |
setLinkStream(MessageStream linkStream)
Sets the ActorStream to the link.
|
java.lang.String getAddress()
java.lang.String getTo()
void message(java.io.Serializable payload)
ActorHolder
,payload
- the message payloadjava.io.Serializable query(java.io.Serializable payload)
queryGet
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 target actor MUST send a queryResult
or
queryError
to the client using the same id
,
because RPC clients rely on a response.payload
- the query payloadjava.io.Serializable query(java.io.Serializable payload, long timeout)
queryGet
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 target actor MUST send a queryResult
or
queryError
to the client using the same id
,
because RPC clients rely on a response.payload
- the query payloadtimeout
- time spent waiting for the query to returnvoid query(java.io.Serializable payload, QueryCallback callback)
queryGet
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 target actor MUST send a queryResult
or
queryError
to the client using the same id
,
because RPC clients rely on a response.to
- the target actor's addresspayload
- the query payloadcallback
- the application's callback for the resultvoid setClientStream(MessageStream clientStream)
MessageStream
with the clientMessageStream getClientStream()
MessageStream
.MessageStream getActorStream()
MessageStream getLinkStream()
void setLinkStream(MessageStream linkStream)
boolean isClosed()
void close()