Actor.RemoteActor (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.actor
[Java] Class Actor.RemoteActor

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.actor.impl.MessageStream
          groovyx.gpars.actor.Actor
              groovyx.gpars.actor.Actor.RemoteActor

All Implemented Interfaces:: RemoteSerialized

public static class Actor.RemoteActor
extends Actor

Nested Class Summary
`static class`	`Actor.RemoteActor.StopActorMsg`
`static class`	`Actor.RemoteActor.TerminateActorMsg`

Field Summary
`private RemoteHost`	`remoteHost`
`private static long`	`serialVersionUID`

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
`Actor.RemoteActor(SerialContext host, DataflowExpression jointLatch)`

Method Summary
`protected boolean`	`hasBeenStopped()`
`boolean`	`isActive()`
`MessageStream`	`send(java.lang.Object message)`
`Actor`	`silentStart()`
`Actor`	`start()`
`Actor`	`stop()`
`protected ActorMessage`	`sweepNextMessage()`
`Actor`	`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

remoteHost

private final RemoteHost remoteHost

serialVersionUID

private static final long serialVersionUID

Constructor Detail

Actor.RemoteActor

public Actor.RemoteActor(SerialContext host, DataflowExpression jointLatch)

Method Detail

hasBeenStopped

@Override
protected boolean hasBeenStopped()

isActive

@Override
public boolean isActive()

send

@SuppressWarnings({"AssignmentToMethodParameter"})
@Override
public MessageStream send(java.lang.Object message)

silentStart

@Override
public Actor silentStart()

start

@Override
public Actor start()

stop

@Override
public Actor stop()

sweepNextMessage

@Override
protected ActorMessage sweepNextMessage()

terminate

@Override
public Actor terminate()

groovyx.gpars.actor [Java] Class Actor.RemoteActor