Package co.paralleluniverse.actors

Class RemoteActor<Message>

java.lang.Object

co.paralleluniverse.actors.ActorImpl<Message>

co.paralleluniverse.actors.RemoteActor<Message>

All Implemented Interfaces:

java.io.Serializable

public abstract class RemoteActor<Message>
extends ActorImpl<Message>

This class should be extended by implementations of remote actors.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	RemoteActor.RemoteActorAdminMessage

Nested classes/interfaces inherited from class co.paralleluniverse.actors.ActorImpl

ActorImpl.ActorLifecycleListener

Field Summary

Fields inherited from class co.paralleluniverse.actors.ActorImpl

flightRecorder, ref

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RemoteActor(ActorRef<Message> actor)

Method Summary

Modifier and Type	Method	Description
protected void	addLifecycleListener(co.paralleluniverse.actors.LifecycleListener listener)
ActorImpl<Message>	getActor()
protected static ActorImpl	getImpl(ActorRef<?> actor)
protected void	handleAdminMessage(RemoteActor.RemoteActorAdminMessage msg)
protected void	internalSend(java.lang.Object message)	For internal use
protected void	internalSendNonSuspendable(java.lang.Object message)
void	interrupt()
protected void	linked(ActorRef actor)
protected void	removeLifecycleListener(co.paralleluniverse.actors.LifecycleListener listener)
protected void	removeObserverListeners(ActorRef observer)
protected void	throwIn(java.lang.RuntimeException e)
boolean	trySend(Message message)
protected void	unlinked(ActorRef actor)

Methods inherited from class co.paralleluniverse.actors.ActorImpl

close, close, getLifecycleListener, getMailbox, getName, isRecordingLevel, mailbox, record, record, record, record, record, record, record, ref, sendOrInterrupt, sendSync, setName, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

RemoteActor

protected RemoteActor(ActorRef<Message> actor)

Method Detail

handleAdminMessage

protected void handleAdminMessage(RemoteActor.RemoteActorAdminMessage msg)

getActor

public ActorImpl<Message> getActor()

internalSend

protected void internalSend(java.lang.Object message)
                     throws SuspendExecution

Description copied from class: ActorImpl

For internal use

Specified by:

internalSend in class ActorImpl<Message>

Throws:

SuspendExecution

internalSendNonSuspendable

protected void internalSendNonSuspendable(java.lang.Object message)

Specified by:

internalSendNonSuspendable in class ActorImpl<Message>

trySend

public boolean trySend(Message message)

Specified by:

trySend in class ActorImpl<Message>

addLifecycleListener

protected void addLifecycleListener(co.paralleluniverse.actors.LifecycleListener listener)

Specified by:

addLifecycleListener in class ActorImpl<Message>

removeLifecycleListener

protected void removeLifecycleListener(co.paralleluniverse.actors.LifecycleListener listener)

Specified by:

removeLifecycleListener in class ActorImpl<Message>

linked

protected void linked(ActorRef actor)

Specified by:

linked in class ActorImpl<Message>

unlinked

protected void unlinked(ActorRef actor)

Specified by:

unlinked in class ActorImpl<Message>

removeObserverListeners

protected void removeObserverListeners(ActorRef observer)

Specified by:

removeObserverListeners in class ActorImpl<Message>

throwIn

protected void throwIn(java.lang.RuntimeException e)

Specified by:

throwIn in class ActorImpl<Message>

interrupt

public void interrupt()

Specified by:

interrupt in class ActorImpl<Message>

getImpl

protected static ActorImpl getImpl(ActorRef<?> actor)