Package net.sodacan.core.actor

Class TimeActor

java.lang.Object

net.sodacan.core.actor.AbstractActor

net.sodacan.core.actor.TimeActor

All Implemented Interfaces:

Closeable, AutoCloseable, Actor, HostBound

public class TimeActor
extends AbstractActor
implements HostBound

This timer actor provides a simple but important service for other Actors: It will accept a message, hold on to the message for a specified amount of time and then forward that message to its next step which could be the Actor that sent the message or any other actor.

This Actor can withstand a Host restart and will send messages it might have missed during any down time.

Nested Class Summary

Nested classes/interfaces inherited from interface net.sodacan.core.Actor

Actor.Builtin

Field Summary

Fields inherited from class net.sodacan.core.actor.AbstractActor

emptyStage, inbound

Constructor Summary

Constructors

Constructor	Description
TimeActor(Config config, ActorId actorId)

Method Summary

Modifier and Type	Method	Description
void	close()

Methods inherited from class net.sodacan.core.actor.AbstractActor

callProcessMessage, evictionProbability, exitingThread, getActorGroup, getActorId, getConfig, getEmptyStage, getLiveActorGroupStatistics, handleStage, nextRoute, processMessage, restore, rollback, save, send, setActorGroup, validateRoute

Methods inherited from class java.lang.Object

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

Constructor Details

TimeActor

public TimeActor(Config config,
 ActorId actorId)

Method Details

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException