eu.larkc.core.executor.pipe
Class Sink

java.lang.Object
  eu.larkc.core.executor.pipe.Sink

public class Sink
extends java.lang.Object

This class implements a sink. A sink is used to get the output of a workflow after executing it and providing the output to endpoints that are connected to this sink.

Author:

norbert

Constructor Summary

Sink()
Constructor to create a new sink.

Method Summary

void	accept(PluginManager.Message next) Sends a message to the plugin manager.
SetOfStatements	getNextResults() Returns the next results that the workflow produces.
void	setPipeOutputQueue(Queue<SetOfStatements> outputQueue) Sets the output queue of the pipe.
void	setPluginManager(PluginManager workflowPluginManager) Setter.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Sink

public Sink()

Constructor to create a new sink.

Method Detail

accept

public void accept(PluginManager.Message next)

Sends a message to the plugin manager.

Parameters:

next -

setPipeOutputQueue

public void setPipeOutputQueue(Queue<SetOfStatements> outputQueue)

Sets the output queue of the pipe.

Parameters:

outputQueue - the ouput queue

getNextResults

public SetOfStatements getNextResults()

Returns the next results that the workflow produces.

Returns:

the next results

setPluginManager

public void setPluginManager(PluginManager workflowPluginManager)

Setter. Sets or updates the workflowPluginManager to the passed value.

Parameters:

workflowPluginManager - the workflowPluginManager to set