com.emphysic.myriad.network

Class LinkedWorkerPool

java.lang.Object

akka.actor.UntypedActor

com.emphysic.myriad.network.WorkerPool

com.emphysic.myriad.network.LinkedWorkerPool

All Implemented Interfaces:

akka.actor.Actor

Direct Known Subclasses:

DataIngestorPool, DatasetOperationPool, PyramidActorPool, ReporterActorPool, ROIFinderPool, SlidingWindowPool

public abstract class LinkedWorkerPool
extends WorkerPool

LinkedWorkerPool - an Akka worker pool that sends its results to another Actor. Conceptually speaking, a linked list of processing steps.

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Field Summary

Fields

Modifier and Type	Field and Description
protected akka.actor.ActorRef	next Next link in the chain

Fields inherited from class com.emphysic.myriad.network.WorkerPool

DEFAULTWORKERS, router

Constructor Summary

Constructors

Constructor and Description
LinkedWorkerPool()

Method Summary

Modifier and Type	Method and Description
akka.actor.ActorRef	getNext() Returns the next link in the chain
akka.actor.ActorRef	getNextActor() Determines the recipient for a message.
void	setNext(akka.actor.ActorRef next) Sets the next link in the chain
void	shutdown() Initiates shutdown procedure.
void	tellNextActor(java.lang.Object message) Sends a message to the next Actor in the chain from this Actor.
void	tellNextActor(java.lang.Object message, akka.actor.ActorRef sender) Sends a message to the next Actor in the chain, or to this instance's parent if next is null.

Methods inherited from class com.emphysic.myriad.network.WorkerPool

genMessage, getRouter, setRouter, start, start, start, tellRouter, tellRouter

Methods inherited from class akka.actor.UntypedActor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, getContext, getSelf, getSender, onReceive, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from class java.lang.Object

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

Field Detail

next

protected akka.actor.ActorRef next

Next link in the chain

Constructor Detail

LinkedWorkerPool

public LinkedWorkerPool()

Method Detail

getNextActor

public akka.actor.ActorRef getNextActor()

Determines the recipient for a message.

Returns:

next link or this Actor's parent if the link is null.

tellNextActor

public void tellNextActor(java.lang.Object message)

Sends a message to the next Actor in the chain from this Actor.

Parameters:

message - message to send to the next Actor

tellNextActor

public void tellNextActor(java.lang.Object message,
                          akka.actor.ActorRef sender)

Sends a message to the next Actor in the chain, or to this instance's parent if next is null.

Parameters:

message - object to send

sender - sender of the message

getNext

public akka.actor.ActorRef getNext()

Returns the next link in the chain

Returns:

next link

setNext

public void setNext(akka.actor.ActorRef next)

Sets the next link in the chain

Parameters:

next - new next

shutdown

public void shutdown()

Initiates shutdown procedure.

Overrides:

shutdown in class WorkerPool