org.eclipse.smila.bulkbuilder.helper
Class BulkbuilderTaskProvider

java.lang.Object
  org.eclipse.smila.bulkbuilder.helper.BulkbuilderTaskProvider

public class BulkbuilderTaskProvider
extends java.lang.Object

Initial task handling. Gets, caches, keeps-alive and finishes (initial) tasks by communicating with taskmanager/jobmanager/workermanager.

Constructor Summary

BulkbuilderTaskProvider(TaskManager taskManager, WorkerManager workerManager, JobRunDataProvider jobDataProvider, JobTaskProcessor jobTaskProcessor, java.lang.String workerName)

Method Summary

void	checkJobActive(java.lang.String jobName)
Task	finishTask(java.lang.String jobName, ResultDescription resultDescription) Finishes a task.
Task	getInitialTask(java.lang.String jobName) Returns the initial task for bulk building.
void	removeTask(Task task) Removes a task.

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkbuilderTaskProvider

public BulkbuilderTaskProvider(TaskManager taskManager,
                               WorkerManager workerManager,
                               JobRunDataProvider jobDataProvider,
                               JobTaskProcessor jobTaskProcessor,
                               java.lang.String workerName)

Method Detail

getInitialTask

public Task getInitialTask(java.lang.String jobName)
                    throws BulkbuilderException

Returns the initial task for bulk building.

Parameters:

jobName - The job name

Returns:

The initial task

Throws:

BulkbuilderException - An exception if something goes wrong

finishTask

public Task finishTask(java.lang.String jobName,
                       ResultDescription resultDescription)
                throws BulkbuilderException

Finishes a task.

Throws:

BulkbuilderException

removeTask

public void removeTask(Task task)

Removes a task.

checkJobActive

public void checkJobActive(java.lang.String jobName)
                    throws BulkbuilderException

Parameters:

jobName - name of job

Throws:

BulkbuilderException - if job is not in state RUNNING or FINISHING