Any Java class can act as a processor in a pipeline by implementing the atg.service.pipeline.PipelineProcessor interface. The PipelineProcessor interface has a single method:

int runProcess(Object pParam, PipelineResult pResult)

The runProcess() method returns an integer status code that the Pipeline Manager uses to determine the next processor to run.