|
| |
|
| java.lang.Object
 org.jicarilla.plumbing.SimpleStage
org.jicarilla.plumbing.DefaultStage
org.jicarilla.plumbing.PreProcessor
| PreProcessor | | public class PreProcessor extends DefaultStage (Code) | | A Preprocessor runs a series of plumbing over a message before enqueueing it:
+-----------------------------------------+
|Preprocessor |
put() |+------+ +------+ +------+ +---------+ take()
------>|Stage1|-->|Stage2|-->|Stage3|-->| Channel |----->
|+------+ +------+ +------+ +---------+
+-----------------------------------------+
Use a Preprocessor when it does not make sense to put any kind of
(asynchronous) buffering between plumbing and it is acceptable for put() to
take a long time.
author:
Leo Simons
version:
$Id: PreProcessor.java,v 1.2 2004/03/23 13:37:58 lsimons Exp $ |
| Constructor Summary | |
| public | PreProcessor(Channel channel, Sink errorHandler)
Create a new instance. |
| m_mutex | | final protected Object m_mutex(Code) | | The mutex to synchronize on for operations involving
m_stages .
|
| PreProcessor | | public PreProcessor(Channel channel, Sink errorHandler)(Code) | | Create a new instance.
Parameters:
channel - the channel to pass to DefaultStage
Parameters:
errorHandler - the error handler to pass to DefaultStage |
| addStage | | public void addStage(Stage stage)(Code) | | Add a stage to the processor. It's appended at the end of the current
set of stages.
Parameters:
stage - the stage to add |
| Fields inherited from org.jicarilla.plumbing.DefaultStage | final protected Sink m_errorHandler(Code)(Java Doc)
|
| Fields inherited from org.jicarilla.plumbing.SimpleStage | protected Channel m_channel(Code)(Java Doc)
|
|
|
|