com.rhi.architecture.parc
Interface Pipeline

All Known Implementing Classes:

AbstractPipeline

public interface Pipeline

Processing pipeline component. Responsible for hooking filter(s) up to an input channel & an output channel & running a them.

Since:

1.0

Author:

Pete McKinstry

Method Summary

void	addFilter(Filter f) Add a filter using the default channel.
void	addFilter(Filter f, Channel c) Add a filer using the provided Channel.
void	flush() Cleanup in-process work and shutdown queues.
Channel	getErrorChannel() Return the error channel to which the pipe is hooked up.
Channel	getInputChannel() Return the input channel to which the pipe is hooked.
Channel	getOutputChannel() Return the output channel to which the pipe is hooked up.
void	init(Channel ch) Allow the framework to provide a default Channel implementation.
void	process() Run the filter.
void	setExceptionHandler(ExceptionHandler handler) Set exception handler instance

Method Detail

init

public void init(Channel ch)
          throws InitializationException

Allow the framework to provide a default Channel implementation.

Parameters:

ch -

Throws:

InitializationException

Since:

1.1

setExceptionHandler

public void setExceptionHandler(ExceptionHandler handler)

Set exception handler instance

Parameters:

handler -

Since:

1.1

process

public void process()
             throws ProcessingException

Run the filter.

Throws:

ProcessingException

Since:

1.0

flush

public void flush()

Cleanup in-process work and shutdown queues.

Since:

1.0

getInputChannel

public Channel getInputChannel()

Return the input channel to which the pipe is hooked.

Returns:

Since:

1.0

getOutputChannel

public Channel getOutputChannel()

Return the output channel to which the pipe is hooked up.

Returns:

Since:

1.0

getErrorChannel

public Channel getErrorChannel()

Return the error channel to which the pipe is hooked up.

Returns:

Since:

1.0

addFilter

public void addFilter(Filter f)

Add a filter using the default channel.

Parameters:

f -

Since:

1.1

addFilter

public void addFilter(Filter f,
                      Channel c)

Add a filer using the provided Channel.

Parameters:

f -

c -

Since:

1.1