org.apache.oodt.cas.workflow.engine

Class PrioritizedQueueBasedWorkflowEngine

java.lang.Object

org.apache.oodt.cas.workflow.engine.PrioritizedQueueBasedWorkflowEngine

All Implemented Interfaces:

WorkflowEngine

public class PrioritizedQueueBasedWorkflowEngine
extends Object
implements WorkflowEngine

Describe your class here.

Version:

$Revision$

Author:

mattmann, bfoster

Field Summary

Fields inherited from interface org.apache.oodt.cas.workflow.engine.WorkflowEngine

X_POINT_ID

Constructor Summary

Constructors

Constructor and Description
PrioritizedQueueBasedWorkflowEngine(WorkflowInstanceRepository repo, PrioritySorter prioritizer, WorkflowLifecycleManager lifecycle, EngineRunner runner, WorkflowRepository modelRepo, long querierWaitSeconds)

Method Summary

Modifier and Type	Method and Description
double	getCurrentTaskWallClockMinutes(String workflowInstId) Gets the amount of wall clock minutes that the particular WorkflowTask within a WorkflowInstance has been executing for.
WorkflowInstanceRepository	getInstanceRepository() Gets the WorkflowInstanceRepository used by this WorkflowEngine.
double	getWallClockMinutes(String workflowInstId) Gets the amount of wall clock minutes that a particular WorkflowInstance (identified by its workflowInst) has been executing.
Metadata	getWorkflowInstanceMetadata(String workflowInstId) Gets the Metadata associated with the WorkflowInstance identified by the given identifier.
void	pauseWorkflowInstance(String workflowInstId) Pauses the WorkflowInstance specified by its workflowInstId.
void	resumeWorkflowInstance(String workflowInstId) Resumes Execution of the specified WorkflowInstance identified by its workflowInstId.
void	setEngineRunner(EngineRunner runner)
void	setWorkflowManagerUrl(URL url) Sets a pointer to the Workflow Manager that this WorkflowEngine belongs to.
WorkflowInstance	startWorkflow(Workflow workflow, Metadata metadata) Starts the specified Workflow by creating a WorkflowInstance, and then running that instance.
void	stopWorkflow(String workflowInstId) Stops the WorkflowInstance identified by the given workflowInstId.
boolean	updateMetadata(String workflowInstId, Metadata met) Updates the Metadata context for the WorkflowInstance identified by the given workflowInstId

Methods inherited from class java.lang.Object

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

Constructor Detail

PrioritizedQueueBasedWorkflowEngine

public PrioritizedQueueBasedWorkflowEngine(WorkflowInstanceRepository repo,
                                           PrioritySorter prioritizer,
                                           WorkflowLifecycleManager lifecycle,
                                           EngineRunner runner,
                                           WorkflowRepository modelRepo,
                                           long querierWaitSeconds)

Method Detail

setEngineRunner

public void setEngineRunner(EngineRunner runner)

startWorkflow

public WorkflowInstance startWorkflow(Workflow workflow,
                                      Metadata metadata)
                               throws EngineException

Description copied from interface: WorkflowEngine

Starts the specified Workflow by creating a WorkflowInstance, and then running that instance. The started WorkflowInstance which is returned, will have its status updated by the workflow engine, including its status field, and its currentTaskId.

Specified by:

startWorkflow in interface WorkflowEngine

Parameters:

workflow - The abstract representation of the Workflow to start.

metadata - Any metadata that needs to be shared between the tasks in the WorkflowInstance.

Returns:

A WorkflowInstance which can be used to monitor the execution of the Workflow through the Engine.

Throws:

EngineException - If any error occurs.

stopWorkflow

public void stopWorkflow(String workflowInstId)

Description copied from interface: WorkflowEngine

Stops the WorkflowInstance identified by the given workflowInstId.

Specified by:

stopWorkflow in interface WorkflowEngine

Parameters:

workflowInstId - The identifier of the WorkflowInstance to stop.

pauseWorkflowInstance

public void pauseWorkflowInstance(String workflowInstId)

Description copied from interface: WorkflowEngine

Pauses the WorkflowInstance specified by its workflowInstId.

Specified by:

pauseWorkflowInstance in interface WorkflowEngine

Parameters:

workflowInstId - The ID of the Workflow Instance to pause.

resumeWorkflowInstance

public void resumeWorkflowInstance(String workflowInstId)

Description copied from interface: WorkflowEngine

Resumes Execution of the specified WorkflowInstance identified by its workflowInstId.

Specified by:

resumeWorkflowInstance in interface WorkflowEngine

Parameters:

workflowInstId - The ID of the WorkflowInstance to resume.

getInstanceRepository

public WorkflowInstanceRepository getInstanceRepository()

Description copied from interface: WorkflowEngine

Gets the WorkflowInstanceRepository used by this WorkflowEngine.

Specified by:

getInstanceRepository in interface WorkflowEngine

Returns:

The WorkflowInstanceRepository used by this WorkflowEngine.

updateMetadata

public boolean updateMetadata(String workflowInstId,
                              Metadata met)

Description copied from interface: WorkflowEngine

Updates the Metadata context for the WorkflowInstance identified by the given workflowInstId

Specified by:

updateMetadata in interface WorkflowEngine

Parameters:

workflowInstId - Identifies the WorkflowInstance whose Metadata context will be updated.

met - The new Metadata context.

Returns:

true if the update was successful, false otherwise.

setWorkflowManagerUrl

public void setWorkflowManagerUrl(URL url)

Description copied from interface: WorkflowEngine

Sets a pointer to the Workflow Manager that this WorkflowEngine belongs to.

Specified by:

setWorkflowManagerUrl in interface WorkflowEngine

Parameters:

url - The URL pointer to the Workflow Manager that this WorkflowEngine belongs to.

getWallClockMinutes

public double getWallClockMinutes(String workflowInstId)

Description copied from interface: WorkflowEngine

Gets the amount of wall clock minutes that a particular WorkflowInstance (identified by its workflowInst) has been executing. This includes time spent QUEUED, time spent WAITING, throughout its entire lifecycle.

Specified by:

getWallClockMinutes in interface WorkflowEngine

Parameters:

workflowInstId - The identifier of the WorkflowInstance to measure wall clock time for.

Returns:

The amount of wall clock minutes that a particular WorkflowInstance has been executing for.

getCurrentTaskWallClockMinutes

public double getCurrentTaskWallClockMinutes(String workflowInstId)

Description copied from interface: WorkflowEngine

Gets the amount of wall clock minutes that the particular WorkflowTask within a WorkflowInstance has been executing for.

Specified by:

getCurrentTaskWallClockMinutes in interface WorkflowEngine

Parameters:

workflowInstId - The identifier of the WorkflowInstance to measure wall clock time for its current WorkflowTask.

Returns:

The amount of wall clock minutes that a particular WorkflowInstance's current WorkflowTask has been executing for.

getWorkflowInstanceMetadata

public Metadata getWorkflowInstanceMetadata(String workflowInstId)

Description copied from interface: WorkflowEngine

Gets the Metadata associated with the WorkflowInstance identified by the given identifier.

Specified by:

getWorkflowInstanceMetadata in interface WorkflowEngine

Parameters:

workflowInstId - The identifier of the WorkflowInstance to obtain the Metadata for.

Returns:

The Metadata shared context of the WorkflowInstance with the given identifier.