org.apache.oodt.cas.workflow.engine.runner

Class EngineRunner

java.lang.Object

org.apache.oodt.cas.workflow.engine.runner.EngineRunner

Direct Known Subclasses:

AbstractEngineRunnerBase

public abstract class EngineRunner
extends Object

Obfuscates the underlying substrate on which a WorkflowTask should run. In short, executes a WorkflowTask for the Workflow Engine.

Version:

$Revision$

Author:

bfoster, mattmann

Constructor Summary

Constructors

Constructor and Description
EngineRunner()

Method Summary

Modifier and Type	Method and Description
abstract void	execute(TaskProcessor taskProcessor) Executes a TaskProcessor on an execution substrate.
abstract boolean	hasOpenSlots(TaskProcessor taskProcessor) Decides whether or not there are available slots within this runner to execute the provided TaskProcessor.
abstract void	setInstanceRepository(WorkflowInstanceRepository instRep)
abstract void	shutdown() Shuts this runner down and frees its resources.

Methods inherited from class java.lang.Object

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

Constructor Detail

EngineRunner

public EngineRunner()

Method Detail

execute

public abstract void execute(TaskProcessor taskProcessor)

Executes a TaskProcessor on an execution substrate. Ideally there will only ever be two of these substrates, one for local execution, and another for communication with the Resource Manager.

Parameters:

taskProcessor - The TaskProcessor to instantiate and execute.

Throws:

Exception - If any error occurs.

shutdown

public abstract void shutdown()

Shuts this runner down and frees its resources.

Throws:

Exception - If any error occurs while freeing resources.

hasOpenSlots

public abstract boolean hasOpenSlots(TaskProcessor taskProcessor)

Decides whether or not there are available slots within this runner to execute the provided TaskProcessor.

Parameters:

taskProcessor - The TaskProcessor to execute.

Returns:

True if there is an open slot, false otherwise.

Throws:

Exception - If any error occurs.

setInstanceRepository

public abstract void setInstanceRepository(WorkflowInstanceRepository instRep)