org.kurator.validation.actors.mapstream

Class EnvironmentTagger

java.lang.Object

akka.actor.UntypedActor

org.kurator.akka.KuratorActor

org.kurator.validation.actors.mapstream.EnvironmentTagger

All Implemented Interfaces:

akka.actor.Actor

public class EnvironmentTagger
extends org.kurator.akka.KuratorActor

Tags occurrence records with inferences about the marine/non-marine environment.

Author:

mole

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 org.kurator.akka.KuratorActor

configuration, endOnEos, EOL, errStream, id, inputs, inStream, name, needsTrigger, outStream, sendEosOnEnd, settings, state, workflowRef

Constructor Summary

Constructors

Constructor and Description
EnvironmentTagger()

Method Summary

Modifier and Type	Method and Description
protected void	onData(Object message)

Methods inherited from class org.kurator.akka.KuratorActor

broadcast, configuration, endStreamAndStop, endStreamAndStop, errorStream, getReceivedWrappedMessage, inputs, inputStream, listeners, logger, metadataReaders, metadataWriters, onEnd, onEndOfStream, onFutureComplete, onInitialize, onReceive, onStart, onTrigger, outputStream, publishArtifact, publishArtifact, publishArtifacts, publishProduct, publishProduct, publishProducts, reportException, runner, setNeedsTrigger, settings

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

EnvironmentTagger

public EnvironmentTagger()

Method Detail

onData

protected void onData(Object message)
               throws Exception

Overrides:

onData in class org.kurator.akka.KuratorActor

Throws:

Exception