org.archive.modules

Class ProcessorChain

java.lang.Object

org.archive.modules.ProcessorChain

All Implemented Interfaces:

Iterable<Processor>, HasKeyedProperties, org.archive.util.Reporter, org.springframework.context.Lifecycle

Direct Known Subclasses:

CandidateChain, DispositionChain, FetchChain

public class ProcessorChain
extends Object
implements Iterable<Processor>, HasKeyedProperties, org.archive.util.Reporter, org.springframework.context.Lifecycle

Collection of Processors to run. Not just a list on another bean so that: - chain is a prominent standalone part of configuration - Lifecycle events may be propagated to members defined as inner beans - future override capability may allow inserts at any place in order, not just end (assuming TBD specialized iterator) See subclasses CandidateChain, FetchChain, and DispositionChain

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ProcessorChain.ChainStatusReceiver

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	isRunning
protected KeyedProperties	kp

Constructor Summary

Constructors

Constructor and Description
ProcessorChain()

Method Summary

Methods

Modifier and Type	Method and Description
KeyedProperties	getKeyedProperties()
List<Processor>	getProcessors()
boolean	isRunning()
Iterator<Processor>	iterator()
void	process(CrawlURI curi, ProcessorChain.ChainStatusReceiver thread)
void	reportTo(PrintWriter writer) Compiles and returns a human readable report on the active processors.
void	setProcessors(List<Processor> processors)
String	shortReportLegend()
void	shortReportLineTo(PrintWriter pw)
Map<String,Object>	shortReportMap()
int	size()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

kp

protected KeyedProperties kp

isRunning

protected boolean isRunning

Constructor Detail

ProcessorChain

public ProcessorChain()

Method Detail

getKeyedProperties

public KeyedProperties getKeyedProperties()

Specified by:

getKeyedProperties in interface HasKeyedProperties

size

public int size()

iterator

public Iterator<Processor> iterator()

Specified by:

iterator in interface Iterable<Processor>

getProcessors

public List<Processor> getProcessors()

setProcessors

public void setProcessors(List<Processor> processors)

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

reportTo

public void reportTo(PrintWriter writer)

Compiles and returns a human readable report on the active processors.

Specified by:

reportTo in interface org.archive.util.Reporter

Parameters:

writer - Where to write to.

See Also:

org.archive.crawler.framework.Processor#report()

shortReportLegend

public String shortReportLegend()

Specified by:

shortReportLegend in interface org.archive.util.Reporter

shortReportMap

public Map<String,Object> shortReportMap()

Specified by:

shortReportMap in interface org.archive.util.Reporter

shortReportLineTo

public void shortReportLineTo(PrintWriter pw)

Specified by:

shortReportLineTo in interface org.archive.util.Reporter

process

public void process(CrawlURI curi,
           ProcessorChain.ChainStatusReceiver thread)
             throws InterruptedException

Throws:

InterruptedException