Package org.webharvest.runtime.processors

Class RunningStatusController<TDef extends IElementDef>

java.lang.Object

org.webharvest.runtime.processors.AbstractProcessorDecorator<TDef>

org.webharvest.runtime.processors.RunningStatusController<TDef>

Type Parameters:

TDef - type of definition of decorated processor

All Implemented Interfaces:

Processor<TDef>

public final class RunningStatusController<TDef extends IElementDef>
extends AbstractProcessorDecorator<TDef>

AbstractProcessorDecorator implementation which decorates Processor#run(Scraper, DynamicScopeContext) method in the way that it enters to the Monitor using Monitor.Guard verifying that processing is not paused. Otherwise it wait until Monitor.Guard allows to continue processing. Monitor and Monitor.Guard instances are retrieved using InjectorHelper.

Since:

2.1-SNAPSHOT

Version:

%I%, %G%

Author:

mczapiewski

Field Summary

Fields inherited from class org.webharvest.runtime.processors.AbstractProcessorDecorator

decoratedProcessor

Constructor Summary

Constructors

Constructor	Description
RunningStatusController(Processor<TDef> decoratedProcessor)	Default class constructor which accepts Processor instance which is going to be decorated by this class.

Method Summary

Modifier and Type	Method	Description
Variable	run(DynamicScopeContext context)

Methods inherited from class org.webharvest.runtime.processors.AbstractProcessorDecorator

getElementDef, getParentProcessor, getRunningLevel, setElementDef, setParentProcessor

Methods inherited from class java.lang.Object

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

Constructor Detail

RunningStatusController

public RunningStatusController(Processor<TDef> decoratedProcessor)

Default class constructor which accepts Processor instance which is going to be decorated by this class.

Parameters:

decoratedProcessor - an instance of Processor which is going to be decorated; must be not null.

Method Detail

run

public Variable run(DynamicScopeContext context)
             throws InterruptedException

Throws:

InterruptedException