org.d_haven.event.command
public class EventPipelineRunner extends Object implements Runnable
Field Summary | |
---|---|
int | m_numEntries |
EventPipeline | m_pipeline |
Constructor Summary | |
---|---|
EventPipelineRunner(EventPipeline pipeline)
Create an EventPipelineRunner with the supplied pipeline and a
policy of dequeueing one entry at a time.
| |
EventPipelineRunner(EventPipeline pipeline, int numEntries)
Create an EventPipelineRunner with the supplied pipeline and
number of events to dequeue at a time. |
Method Summary | |
---|---|
int | getNumEntries()
Return the number of entries to process at one time.
|
EventPipeline | getPipeline()
Get the pipeline we are processing at this time.
|
void | run()
The run method will process events once and then end. |
String | toString() |
Parameters: pipeline the pipeline to run
Parameters: pipeline the pipeline to run numEntries the number of entries to dequeue
Returns: the number of entries as an integer
Returns: the pipeline we are running