com.emphysic.myriad.network

Class ROIFinderPool

java.lang.Object

akka.actor.UntypedActor

com.emphysic.myriad.network.WorkerPool

com.emphysic.myriad.network.LinkedWorkerPool

com.emphysic.myriad.network.ROIFinderPool

All Implemented Interfaces:

akka.actor.Actor

public class ROIFinderPool
extends LinkedWorkerPool

ROIFinderPool - linked worker pool of Region Of Interest (ROI) detectors

Nested Class Summary

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

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

Field Summary

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
ROIFinderPool(int numWorkers, ROIFinder finder) Creates a new ROIFinderPool.
ROIFinderPool(ROIFinder finder) Creates a new ROIFinderPool

Method Summary

Modifier and Type	Method and Description
void	onReceive(java.lang.Object message) Handled Messages DatasetMessage - sends to router for ROI detection ROIMessage - sends to next link in the processing chain ActorRef - sets next link in the processing chain ShutdownMessage - initiates shutdown

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

Constructor Detail

ROIFinderPool

public ROIFinderPool(int numWorkers,
                     ROIFinder finder)

Creates a new ROIFinderPool.

Parameters:

numWorkers - number of workers in the pool

finder - ROI detector to use

ROIFinderPool

public ROIFinderPool(ROIFinder finder)

Creates a new ROIFinderPool

Parameters:

finder - ROI detector to use

Method Detail

onReceive

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

Handled Messages DatasetMessage - sends to router for ROI detection ROIMessage - sends to next link in the processing chain ActorRef - sets next link in the processing chain ShutdownMessage - initiates shutdown

Specified by:

onReceive in class akka.actor.UntypedActor

Throws:

java.lang.Exception