cloud.orbit.actors.runtime

Class ActorEntry<T extends AbstractActor>

java.lang.Object

cloud.orbit.actors.runtime.ActorBaseEntry<T>

cloud.orbit.actors.runtime.ActorEntry<T>

All Implemented Interfaces:

LocalObjects.LocalObjectEntry<T>

public class ActorEntry<T extends AbstractActor>
extends ActorBaseEntry<T>

Field Summary

Fields inherited from class cloud.orbit.actors.runtime.ActorBaseEntry

lastAccess, runtime

Constructor Summary

Constructors

Constructor and Description
ActorEntry(RemoteReference reference)

Method Summary

Modifier and Type	Method and Description
protected Task<T>	activate()
<T> void	addStreamSubscription(StreamSubscriptionHandle<T> subscription, AsyncStream<T> stream)
void	addTimer(Registration registration)
Task<Void>	clearStreamSubscriptions()
void	clearTimers()
Task<Void>	deactivate() This must not fail.
protected Task<Void>	deactivate(T actor)
protected Task<Void>	doDeactivate()
Object	getKey()
T	getObject()
<T> void	removeStreamSubscription(StreamSubscriptionHandle<T> subscription, AsyncStream<T> stream)
<R> Task<R>	run(TaskFunction<LocalObjects.LocalObjectEntry<T>,R> function)
void	setKey(Object key)
void	updateLastAccessTime()

Methods inherited from class cloud.orbit.actors.runtime.ActorBaseEntry

getLastAccess, getLogger, getRemoteReference, isDeactivated, setConcreteClass, setDeactivated, setExecutionSerializer, setLoggerExtension, setRuntime, setStorageExtension

Methods inherited from class java.lang.Object

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

Constructor Detail

ActorEntry

public ActorEntry(RemoteReference reference)

Method Detail

getObject

public T getObject()

run

public <R> Task<R> run(TaskFunction<LocalObjects.LocalObjectEntry<T>,R> function)

Specified by:

run in interface LocalObjects.LocalObjectEntry<T extends AbstractActor>

Overrides:

run in class ActorBaseEntry<T extends AbstractActor>

updateLastAccessTime

public void updateLastAccessTime()

activate

protected Task<T> activate()

deactivate

public Task<Void> deactivate()

This must not fail. If errors it should log them instead of throwing

Specified by:

deactivate in class ActorBaseEntry<T extends AbstractActor>

doDeactivate

protected Task<Void> doDeactivate()

deactivate

protected Task<Void> deactivate(T actor)

getKey

public Object getKey()

setKey

public void setKey(Object key)

addTimer

public void addTimer(Registration registration)

clearTimers

public void clearTimers()

addStreamSubscription

public <T> void addStreamSubscription(StreamSubscriptionHandle<T> subscription,
                                      AsyncStream<T> stream)

removeStreamSubscription

public <T> void removeStreamSubscription(StreamSubscriptionHandle<T> subscription,
                                         AsyncStream<T> stream)

clearStreamSubscriptions

public Task<Void> clearStreamSubscriptions()