com.emphysic.myriad.network

Class ReporterActorPool

java.lang.Object

akka.actor.UntypedActor

com.emphysic.myriad.network.WorkerPool

com.emphysic.myriad.network.LinkedWorkerPool

com.emphysic.myriad.network.ReporterActorPool

All Implemented Interfaces:

akka.actor.Actor

public class ReporterActorPool
extends LinkedWorkerPool

ReporterActorPool - linked worker pool for examining Region Of Interest (ROI) results TODO: convert to streaming reporting

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
(package private) java.util.List<ROIMessage>	rois List of Regions Of Interest (ROI) detected

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

next

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

DEFAULTWORKERS, router

Constructor Summary

Constructors

Constructor and Description
ReporterActorPool() Creates a new pool
ReporterActorPool(int numWorkers) Creates a new pool with the default ReporterActor
ReporterActorPool(int numWorkers, java.lang.Class<? extends ReporterActor> reporter) Creates a new pool
ReporterActorPool(int numWorkers, java.lang.Class<? extends ReporterActor> reporter, java.lang.Object... args) Creates a new pool.

Method Summary

Modifier and Type	Method and Description
java.util.List<ROIMessage>	getROIS() Returns the current list of ROIs
void	onReceive(java.lang.Object message) Handled Messages ROIMessage - if from worker pool, adds to ROI.

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

getNext, getNextActor, setNext, shutdown, tellNextActor, tellNextActor

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, 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

rois

java.util.List<ROIMessage> rois

List of Regions Of Interest (ROI) detected

Constructor Detail

ReporterActorPool

public ReporterActorPool(int numWorkers,
                         java.lang.Class<? extends ReporterActor> reporter,
                         java.lang.Object... args)

Creates a new pool.

Parameters:

numWorkers - number of workers in the pool

reporter - type of reporter to use

args - constructor arguments for the reporter

ReporterActorPool

public ReporterActorPool(int numWorkers,
                         java.lang.Class<? extends ReporterActor> reporter)

Creates a new pool

Parameters:

numWorkers - number of workers in the pool

reporter - type of reporter to use

ReporterActorPool

public ReporterActorPool(int numWorkers)

Creates a new pool with the default ReporterActor

Parameters:

numWorkers - number of workers in the pool

ReporterActorPool

public ReporterActorPool()

Creates a new pool

Method Detail

onReceive

public void onReceive(java.lang.Object message)
               throws java.lang.Exception

Handled Messages ROIMessage - if from worker pool, adds to ROI. Otherwise sends to pool for processing. ShutdownMessage - initiates shutdown

Specified by:

onReceive in class akka.actor.UntypedActor

Throws:

java.lang.Exception

getROIS

public java.util.List<ROIMessage> getROIS()

Returns the current list of ROIs

Returns:

list of ROIs