InternalActor (org.codehaus.gpars)

Overview

Package

Class

Deprecated

Index

Help

org.codehaus.gpars

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

groovyx.gpars.activeobject
[Java] Class InternalActor

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.actor.impl.MessageStream
          groovyx.gpars.actor.Actor
              groovyx.gpars.actor.AbstractLoopingActor
                  groovyx.gpars.activeobject.InternalActor

@java.lang.SuppressWarnings});
public final class InternalActor
extends AbstractLoopingActor

Backs active objects and invokes all object's active methods.

Authors:: Vaclav Pech

Field Summary
`static java.lang.String`	`METHOD_NAME_PREFIX`
`private static java.lang.Object[]`	`No_ARGS`
`private static long`	`serialVersionUID`

Fields inherited from class AbstractLoopingActor
core, currentSender, currentTimerTask, serialVersionUID, stoppedFlag, terminatedFlag, terminatingFlag, timeoutCounter

Fields inherited from 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

Fields inherited from class MessageStream
serialVersionUID

Fields inherited from class WithSerialId
serialHandle, serialVersionUID

Constructor Summary
`InternalActor()`

Method Summary
`static InternalActor`	`create(java.lang.Object groupId)`
`private static java.lang.Object`	`handleCurrentMessage(java.lang.Object msg)`
`void`	`onMessage(java.lang.Object[] msg)`
`DataflowVariable`	`submit(java.lang.Object... args)`
`java.lang.Object`	`submitAndWait(java.lang.Object... args)` Handles incoming messages

Methods inherited from class AbstractLoopingActor
cancelCurrentTimeoutTask, doStart, getCore, getSender, hasBeenStopped, initialize, isActive, isFair, makeFair, reply, replyIfExists, runEnhancedWithoutRepliesOnMessages, send, setParallelGroup, setTimeout, silentStart, start, stop, sweepNextMessage, terminate

Methods inherited from class Actor
callDynamic, createActorMessage, createRemoteHandle, deregisterCurrentActorWithThread, getJoinLatch, getParallelGroup, handleException, handleInterrupt, handleStart, handleTermination, handleTimeout, hasBeenStopped, isActive, isActorThread, join, join, join, join, onStop, registerCurrentActorWithThread, sendAndContinue, sendAndPromise, setParallelGroup, silentStart, start, stop, sweepNextMessage, sweepQueue, terminate, threadBoundActor

Methods inherited from class Actor

callDynamic, createActorMessage, createRemoteHandle, deregisterCurrentActorWithThread, getJoinLatch, getParallelGroup, handleException, handleInterrupt, handleStart, handleTermination, handleTimeout, hasBeenStopped, isActive, isActorThread, join, join, join, join, onStop, registerCurrentActorWithThread, sendAndContinue, sendAndPromise, setParallelGroup, silentStart, start, stop, sweepNextMessage, sweepQueue, terminate, threadBoundActor

Methods inherited from class MessageStream
call, getRemoteClass, leftShift, reInterrupt, send, send, send, sendAndWait, sendAndWait, sendAndWait

Methods inherited from class WithSerialId
createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace

Field Detail

METHOD_NAME_PREFIX

public static final java.lang.String METHOD_NAME_PREFIX

No_ARGS

private static final java.lang.Object[] No_ARGS

serialVersionUID

private static final long serialVersionUID

Constructor Detail

InternalActor

public InternalActor()

Method Detail

create

public static InternalActor create(java.lang.Object groupId)

handleCurrentMessage

@java.lang.SuppressWarnings
private static java.lang.Object handleCurrentMessage(java.lang.Object msg)

onMessage

@java.lang.SuppressWarningsfinal Object[] args = params.length > 2 ? Arrays.copyOfRange(params, 2, params.length) : No_ARGS;
public void onMessage(java.lang.Object[] msg)

submit

DataflowVariable submit(java.lang.Object... args)

submitAndWait

@java.lang.SuppressWarnings({"unchecked", "MethodMayBeStatic"})
java.lang.Object submitAndWait(java.lang.Object... args)

Handles incoming messages

Parameters:: msg - The message representing the requested method call

groovyx.gpars.activeobject [Java] Class InternalActor