com.emphysic.myriad.network

Class DatasetActor

java.lang.Object

akka.actor.UntypedActor

com.emphysic.myriad.network.DatasetActor

All Implemented Interfaces:

akka.actor.Actor

public class DatasetActor
extends akka.actor.UntypedActor

DatasetActor - Akka actor that performs a DatasetOperation on a Dataset.

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) DatasetOperation	op Operation to perform

Constructor Summary

Constructors

Constructor and Description
DatasetActor(DatasetOperation operation) Creates a new DatasetActor with a DatasetOperation

Method Summary

Modifier and Type	Method and Description
void	onReceive(java.lang.Object message) Handled Messages DatasetMessage - performs the DatasetOperation on the message payload, sends DatasetMessage with result back to sender.
void	setOperation(DatasetOperation operation) Sets the operation to perform on each Dataset

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

op

DatasetOperation op

Operation to perform

Constructor Detail

DatasetActor

public DatasetActor(DatasetOperation operation)

Creates a new DatasetActor with a DatasetOperation

Parameters:

operation - operation to perform on each Dataset

Method Detail

setOperation

public void setOperation(DatasetOperation operation)

Sets the operation to perform on each Dataset

Parameters:

operation - new operation to perform

onReceive

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

Handled Messages DatasetMessage - performs the DatasetOperation on the message payload, sends DatasetMessage with result back to sender.

Specified by:

onReceive in class akka.actor.UntypedActor

Throws:

java.lang.Exception