org.kurator.validation.actors.mapstream

Class StreamMerge

java.lang.Object

akka.actor.UntypedActor

org.kurator.akka.KuratorActor

org.kurator.validation.actors.mapstream.StreamMerge

All Implemented Interfaces:

akka.actor.Actor

public class StreamMerge
extends org.kurator.akka.KuratorActor

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, logger, name, needsTrigger, outStream, sendEosOnEnd, settings, state, workflowRef

Constructor Summary

Constructors

Constructor and Description
StreamMerge()

Method Summary

Modifier and Type	Method and Description
protected void	onData(Object message)
protected void	onEndOfStream(org.kurator.akka.messages.EndOfStream eos) Implementation of onEndOfStream that waits for all input streams to send end of stream messages before triggering end of stream and stop.
void	setEndOnEos(boolean endOnEos)
void	setNumberOfInputs(int numberOfInputs)

Methods inherited from class org.kurator.akka.KuratorActor

broadcast, configuration, endStreamAndStop, endStreamAndStop, errorStream, getReceivedWrappedMessage, inputs, inputStream, listeners, logger, metadataReaders, metadataWriters, onEnd, 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

StreamMerge

public StreamMerge()

Method Detail

setNumberOfInputs

public void setNumberOfInputs(int numberOfInputs)

setEndOnEos

public void setEndOnEos(boolean endOnEos)

onEndOfStream

protected void onEndOfStream(org.kurator.akka.messages.EndOfStream eos)
                      throws Exception

Implementation of onEndOfStream that waits for all input streams to send end of stream messages before triggering end of stream and stop. Assumes message delivery model of at most once.

Overrides:

onEndOfStream in class org.kurator.akka.KuratorActor

Parameters:

eos - end of stream signal.

Throws:

Exception

onData

protected void onData(Object message)
               throws Exception

Overrides:

onData in class org.kurator.akka.KuratorActor

Throws:

Exception