Backs active objects and invokes all object's active methods.
Modifiers | Name | Description |
---|---|---|
static java.lang.String |
METHOD_NAME_PREFIX |
|
private static java.lang.Object[] |
No_ARGS |
|
private static long |
serialVersionUID |
Fields inherited from class | Fields |
---|---|
class AbstractLoopingActor |
core, currentSender, currentTimerTask, serialVersionUID, stoppedFlag, terminatedFlag, terminatingFlag, timeoutCounter |
class Actor |
ACTOR_HAS_ALREADY_BEEN_STARTED, AFTER_START, CANNOT_SEND_REPLIES_NO_SENDER_HAS_BEEN_REGISTERED, EMPTY_ARGUMENTS, ON_DELIVERY_ERROR, RESPONDS_TO, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT, TIMEOUT_MESSAGE, currentActorPerThread, currentThread, joinLatch, onStop, parallelGroup, serialVersionUID, timer |
class MessageStream |
serialVersionUID |
class WithSerialId |
serialHandle, serialVersionUID |
Constructor and description |
---|
InternalActor
() Just like DynamicDispatchActor, except that the actual method dispatch is static through the closure passed to the initialize() method. |
Type | Name and description |
---|---|
static InternalActor |
create(java.lang.Object groupId) |
private static java.lang.Object |
handleCurrentMessage(java.lang.Object msg) |
void |
onMessage(java.lang.Object[] msg) Handles incoming messages |
DataflowVariable<java.lang.Object> |
submit(java.lang.Object... args) A DataflowVariable is passed to the actor, which will bind it once the result is known. |
java.lang.Object |
submitAndWait(java.lang.Object... args) A DataflowVariable is passed to the actor, which will bind it once the result is known. |
Just like DynamicDispatchActor, except that the actual method dispatch is static through the closure passed to the initialize() method.
Handles incoming messages
msg
- The message representing the requested method callA DataflowVariable is passed to the actor, which will bind it once the result is known.
args
- The method parametersA DataflowVariable is passed to the actor, which will bind it once the result is known. The method blocks waiting for the Promise to hold a value. The value is then returned back to the caller.
args
- The method parametersCopyright © 2008–2014 Václav Pech. All Rights Reserved.