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

java.lang.Object
  de.ukn.hci.squidy.manager.model.Processable
      de.ukn.hci.squidy.manager.model.Piping
          de.ukn.hci.squidy.manager.model.Node
              de.ukn.hci.squidy.manager.model.AbstractNode

All Implemented Interfaces:

ILaunchable, IProcessable<Processable>

Direct Known Subclasses:

EmptyNode

public class AbstractNode
extends Node

AbstractValve.

 Date: Feb 22, 2009
 Time: 11:54:49 PM
 

Since:

1.0.0

Version:

$Id: AbstractNode.java 254 2010-04-19 17:28:04Z raedle $

Author:

Roman R&aumldle
Roman.Raedle@uni-konstanz .de
Human-Computer Interaction Group
University of Konstanz

Field Summary

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

AbstractNode()

Method Summary

void	delete() Allows to delete the IProcessable implementing class.
ConcurrentLinkedQueue<IDataContainer>	getDataQueue()
void	onStart()
void	onStop()
IDataContainer	postProcess(IDataContainer dataContainer)
IDataContainer	preProcess(IDataContainer dataContainer)
IDataContainer	process(IDataContainer dataContainer) Processes the data container and returns the processed result of the data container.
void	publish(Collection<? extends IData> data) Publishes data objects to all outgoing connected processables.
void	publish(IData... data) Publishes data objects to all outgoing connected processables.
void	publish(IDataContainer dataContainer) Publishes a data container to all outgoing connected processables.
void	start() Allows to start the IProcessable implementing class.
void	stop() Allows to stop the IProcessable implementing class.

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

addIssue, getIssuable, getIssues, hasIssues, removeIssue, setIssuable

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

addDataVisitorFactory, addIncomingPipe, addOutgoingPipe, attachVisitors, getIncomingPipes, getOutgoingPipes, getPipes, notifyVisitors, removeDataVisitorFactory, removeIncomingPipe, removeOutgoingPipe, setIncomingPipes, setOutgoingPipes, setPipes, 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

Constructor Detail

AbstractNode

public AbstractNode()

Method Detail

getDataQueue

public final ConcurrentLinkedQueue<IDataContainer> getDataQueue()

start

public final 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 final 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.

onStart

public void onStart()

onStop

public void onStop()

process

public final IDataContainer process(IDataContainer dataContainer)

Description copied from interface: IProcessable

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

Parameters:

dataContainer - The data container to be processed.

Returns:

The result of the process.

preProcess

public IDataContainer preProcess(IDataContainer dataContainer)

Parameters:

dataContainer -

Returns:

postProcess

public IDataContainer postProcess(IDataContainer dataContainer)

Parameters:

dataContainer -

Returns:

publish

public final void publish(IDataContainer dataContainer)

Publishes a data container to all outgoing connected processables.

Parameters:

dataContainer - The data container that gets published.

publish

public final void publish(IData... data)

Publishes data objects to all outgoing connected processables.

Parameters:

data - The data objects that get published.

See Also:

ReflectionProcessable#publish(IDataContainer)

publish

public final void publish(Collection<? extends IData> data)

Publishes data objects to all outgoing connected processables.

Parameters:

data - The data objects that get published.

See Also:

ReflectionProcessable#publish(IData...)