org.apache.excalibur.event.command

Class AbstractThreadManager.PipelineRunner

java.lang.Object

org.apache.avalon.framework.logger.AbstractLogEnabled

org.apache.excalibur.event.command.AbstractThreadManager.PipelineRunner

All Implemented Interfaces:

java.lang.Runnable, org.apache.avalon.framework.logger.LogEnabled

Enclosing class:

AbstractThreadManager

public static final class AbstractThreadManager.PipelineRunner
extends org.apache.avalon.framework.logger.AbstractLogEnabled
implements java.lang.Runnable

The PipelineRunner class pulls all the events from the Source, and puts them in the EventHandler. Both of those objects are part of the EventPipeline.

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.excalibur.event.command.EventPipeline	m_pipeline The pipeline we are managing

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractThreadManager.PipelineRunner(org.apache.excalibur.event.command.EventPipeline pipeline) Create a PipelineRunner.

Method Summary

Methods

Modifier and Type	Method and Description
void	run() The code that actually pulls the events from the Sources and sends them to the event handler

Methods inherited from class org.apache.avalon.framework.logger.AbstractLogEnabled

enableLogging, getLogger, setupLogger, setupLogger, setupLogger

Methods inherited from class java.lang.Object

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

Field Detail

m_pipeline

private final org.apache.excalibur.event.command.EventPipeline m_pipeline

The pipeline we are managing

Constructor Detail

AbstractThreadManager.PipelineRunner

protected AbstractThreadManager.PipelineRunner(org.apache.excalibur.event.command.EventPipeline pipeline)

Create a PipelineRunner.

Parameters:

pipeline - The EventPipeline we are running

Method Detail

run

public void run()

The code that actually pulls the events from the Sources and sends them to the event handler

Specified by:

run in interface java.lang.Runnable