com.rhi.architecture.parc
Class ParallelMTPipeline

java.lang.Object
  com.rhi.architecture.parc.AbstractPipeline
      com.rhi.architecture.parc.ParallelMTPipeline

All Implemented Interfaces:

Pipeline

public class ParallelMTPipeline

extends AbstractPipeline

Processing pipeline component. Responsible for running the filters and pushing the results into the output adapter.

Since:

1.0

Author:

Pete McKinstry

Constructor Summary

ParallelMTPipeline()
Default Constructor.

Method Summary

void	flush() Cleanup in-process work and shutdown queues.
void	init(Channel ch) initialize the pipeline.
void	process() Run the filter set.

Methods inherited from class com.rhi.architecture.parc.AbstractPipeline

addFilter, addFilter, getErrorChannel, getExceptionHandler, getFilters, getInputChannel, getOutputChannel, log, setExceptionHandler, stopFilters

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelMTPipeline

public ParallelMTPipeline()

Default Constructor. Defaults Channel to general purpose implementation

Since:

1.0

Method Detail

init

public void init(Channel ch)
          throws InitializationException

initialize the pipeline.

Specified by:

init in interface Pipeline

Overrides:

init in class AbstractPipeline

Parameters:

ch -

Throws:

InitializationException

See Also:

Pipeline.init(com.rhi.architecture.parc.Channel)

process

public void process()
             throws ProcessingException

Run the filter set.

Throws:

ProcessingException

Since:

1.0

flush

public void flush()

Cleanup in-process work and shutdown queues.

Since:

1.0