de.ukn.hci.squidy.manager.model
Class Pipe

java.lang.Object
  de.ukn.hci.squidy.manager.model.Processable
      de.ukn.hci.squidy.manager.model.Pipe

All Implemented Interfaces:

ILaunchable, IProcessable<Processable>, ProcessingFeedbackable

public class Pipe
extends Processable
implements ProcessingFeedbackable

Pipe.

 Date: Feb 14, 2008
 Time: 5:51:29 PM
 

Version:

$Id: Pipe.java 142 2010-01-09 20:39:02Z zeitler $$

Author:

Roman Rädle, Roman. Raedle@uni-konstanz.de, University of Konstanz

Field Summary

Processable	source
Processable	target

Fields inherited from class de.ukn.hci.squidy.manager.model.Processable

processing, PROPERTY_DELETE, PROPERTY_FAILURE_PUBLISH, PROPERTY_FAILURE_RESOLVE, PROPERTY_PROCESSING_START, PROPERTY_PROCESSING_STOP

Constructor Summary

Pipe()

Method Summary

void	addProcessingFeedback(ProcessingFeedback feedback)
void	delete() Allows to delete the IProcessable implementing class.
Collection<Class<? extends IData>>	getInputTypes()
Collection<Class<? extends IData>>	getOutputTypes()
Processable	getSource()
Processable	getTarget()
IDataContainer	process(IDataContainer dataContainer) Processes the data container and returns the processed result of the data container.
void	publish(IData... data) Publishs data objects to connected processables.
void	publish(IDataContainer dataContainer) Publishs a data container to connected processables.
void	removeProcessingFeedback(ProcessingFeedback feedback)
void	setInputTypes(Collection<Class<? extends IData>> inputTypes)
void	setOutputTypes(Collection<Class<? extends IData>> outputTypes)
void	setSource(Processable source)
void	setTarget(Processable target)
void	start() Allows to start the IProcessable implementing class.
void	stop() Allows to stop the IProcessable implementing class.
String	toString()

Methods inherited from class de.ukn.hci.squidy.manager.model.Processable

addPropertyChangeListener, addPropertyChangeListener, addSubProcessable, firePropertyChange, getId, getParent, getSubProcessables, isProcessing, postStopSubProcessables, preStartSubProcessables, publishFailure, removeStateChangeListener, removeStateChangeListener, removeSubProcessable, resolveFailure, setId, setParent, setSubProcessables

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

source

public Processable source

target

public Processable target

Constructor Detail

Pipe

public Pipe()

Method Detail

getSource

public Processable getSource()

Returns:

setSource

public void setSource(Processable source)

Parameters:

source -

getTarget

public Processable getTarget()

setTarget

public void setTarget(Processable target)

getInputTypes

public final Collection<Class<? extends IData>> getInputTypes()

Returns:

the inputTypes

setInputTypes

public final void setInputTypes(Collection<Class<? extends IData>> inputTypes)

Parameters:

inputTypes - the inputTypes to set

getOutputTypes

public final Collection<Class<? extends IData>> getOutputTypes()

Returns:

the outputTypes

setOutputTypes

public final void setOutputTypes(Collection<Class<? extends IData>> outputTypes)

Parameters:

outputTypes - the outputTypes to set

process

public IDataContainer process(IDataContainer dataContainer)

Description copied from interface: IProcessable

Processes the data container and returns the processed result of the data container.

Specified by:

process in interface IProcessable<Processable>

Parameters:

dataContainer - The data container to be processed.

Returns:

The result of the process.

publish

public void publish(IData... data)

Description copied from interface: IProcessable

Publishs data objects to connected processables.

Specified by:

publish in interface IProcessable<Processable>

Parameters:

data - The data objects to be published.

publish

public void publish(IDataContainer dataContainer)

Description copied from interface: IProcessable

Publishs a data container to connected processables.

Specified by:

publish in interface IProcessable<Processable>

start

public void start()
           throws ProcessException

Description copied from interface: ILaunchable

Allows to start the IProcessable implementing class.

Specified by:

start in interface ILaunchable

Overrides:

start in class Processable

Throws:

ProcessException - Exception can occur while trying to start the IProcessable.

stop

public void stop()
          throws ProcessException

Description copied from interface: ILaunchable

Allows to stop the IProcessable implementing class.

Specified by:

stop in interface ILaunchable

Overrides:

stop in class Processable

Throws:

ProcessException - Exception can occur while trying to stop the IProcessable.

delete

public void delete()
            throws ProcessException

Description copied from interface: ILaunchable

Allows to delete the IProcessable implementing class.

Specified by:

delete in interface ILaunchable

Overrides:

delete in class Processable

Throws:

ProcessException - Exception can occur while trying to stop the IProcessable.

addProcessingFeedback

public void addProcessingFeedback(ProcessingFeedback feedback)

Specified by:

addProcessingFeedback in interface ProcessingFeedbackable

removeProcessingFeedback

public void removeProcessingFeedback(ProcessingFeedback feedback)

Specified by:

removeProcessingFeedback in interface ProcessingFeedbackable

toString

public String toString()

Overrides:

toString in class Object