com.rhi.architecture.parc
Class SerialMTPipeline

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

All Implemented Interfaces:

Pipeline

public class SerialMTPipeline

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

SerialMTPipeline()
Constructor.

Method Summary

void	flush() Cleanup in-process work and shutdown queues.
void	init(Channel ch) Set the default channel
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

SerialMTPipeline

public SerialMTPipeline()

Constructor. takes single parameter equal to the number of threads of each filter. Defaults Channel to general purpose implementation

Since:

1.0

Method Detail

init

public void init(Channel ch)
          throws InitializationException

Set the default channel

Specified by:

init in interface Pipeline

Overrides:

init in class AbstractPipeline

Parameters:

ch -

Throws:

InitializationException

Since:

1.1

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