org.opennms.core.tasks
Class DefaultTaskCoordinator

java.lang.Object
  org.opennms.core.tasks.DefaultTaskCoordinator

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean

public class DefaultTaskCoordinator
extends Object
implements org.springframework.beans.factory.InitializingBean

TaskCoordinator

Version:

$Id: $

Author:

brozow

Constructor Summary

DefaultTaskCoordinator(String name)
Constructor for DefaultTaskCoordinator.

DefaultTaskCoordinator(String name, Executor defaultExecutor)
Constructor for DefaultTaskCoordinator.

Method Summary

void	addDependency(Task prereq, Task dependent) addDependency
void	addExecutor(String executorName, Executor executor) addExecutor
void	afterPropertiesSet() afterPropertiesSet
TaskBuilder<BatchTask>	createBatch() createBatch
TaskBuilder<BatchTask>	createBatch(ContainerTask<?> parent) createBatch
BatchTask	createBatch(ContainerTask<?> parent, Runnable... tasks) createBatch
BatchTask	createBatch(Runnable... tasks) createBatch
TaskBuilder<SequenceTask>	createSequence() createSequence
TaskBuilder<SequenceTask>	createSequence(ContainerTask<?> parent) createSequence
SequenceTask	createSequence(ContainerTask<?> parent, Runnable... tasks) createSequence
SequenceTask	createSquence(Runnable... tasks) createSquence
<T> AsyncTask<T>	createTask(ContainerTask<?> parent, Async<T> async, Callback<T> cb) createTask
SyncTask	createTask(ContainerTask<?> parent, Runnable r) createTask
SyncTask	createTask(ContainerTask<?> parent, Runnable r, String schedulingHint) createTask
void	schedule(Task task) schedule
void	setDefaultExecutor(String executorName) setDefaultExecutor
void	setExecutors(Map<String,Executor> executors) setExecutors
void	setLoopDelay(long millis) setLoopDelay

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTaskCoordinator

public DefaultTaskCoordinator(String name)

Constructor for DefaultTaskCoordinator.

Parameters:

name - a String object.

DefaultTaskCoordinator

public DefaultTaskCoordinator(String name,
                              Executor defaultExecutor)

Constructor for DefaultTaskCoordinator.

Parameters:

name - a String object.

defaultExecutor - a Executor object.

Method Detail

setDefaultExecutor

public void setDefaultExecutor(String executorName)

setDefaultExecutor

Parameters:

executorName - a String object.

afterPropertiesSet

public void afterPropertiesSet()

afterPropertiesSet

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

createTask

public SyncTask createTask(ContainerTask<?> parent,
                           Runnable r)

createTask

Parameters:

parent - a ContainerTask object.

r - a Runnable object.

Returns:

a SyncTask object.

createTask

public SyncTask createTask(ContainerTask<?> parent,
                           Runnable r,
                           String schedulingHint)

createTask

Parameters:

parent - a ContainerTask object.

r - a Runnable object.

schedulingHint - a String object.

Returns:

a SyncTask object.

createTask

public <T> AsyncTask<T> createTask(ContainerTask<?> parent,
                                   Async<T> async,
                                   Callback<T> cb)

createTask

Type Parameters:

T - a T object.

Parameters:

parent - a ContainerTask object.

async - a Async object.

cb - a Callback object.

Returns:

a AsyncTask object.

createBatch

public TaskBuilder<BatchTask> createBatch(ContainerTask<?> parent)

createBatch

Parameters:

parent - a ContainerTask object.

Returns:

a TaskBuilder object.

createBatch

public TaskBuilder<BatchTask> createBatch()

createBatch

Returns:

a TaskBuilder object.

createBatch

public BatchTask createBatch(ContainerTask<?> parent,
                             Runnable... tasks)

createBatch

Parameters:

parent - a ContainerTask object.

tasks - a Runnable object.

Returns:

a BatchTask object.

createBatch

public BatchTask createBatch(Runnable... tasks)

createBatch

Parameters:

tasks - a Runnable object.

Returns:

a BatchTask object.

createSequence

public TaskBuilder<SequenceTask> createSequence(ContainerTask<?> parent)

createSequence

Parameters:

parent - a ContainerTask object.

Returns:

a TaskBuilder object.

createSequence

public TaskBuilder<SequenceTask> createSequence()

createSequence

Returns:

a TaskBuilder object.

createSequence

public SequenceTask createSequence(ContainerTask<?> parent,
                                   Runnable... tasks)

createSequence

Parameters:

parent - a ContainerTask object.

tasks - a Runnable object.

Returns:

a SequenceTask object.

createSquence

public SequenceTask createSquence(Runnable... tasks)

createSquence

Parameters:

tasks - a Runnable object.

Returns:

a SequenceTask object.

setLoopDelay

public void setLoopDelay(long millis)

setLoopDelay

Parameters:

millis - a long.

schedule

public void schedule(Task task)

schedule

Parameters:

task - a Task object.

addDependency

public void addDependency(Task prereq,
                          Task dependent)

addDependency

Parameters:

prereq - a Task object.

dependent - a Task object.

addExecutor

public void addExecutor(String executorName,
                        Executor executor)

addExecutor

Parameters:

executorName - a String object.

executor - a Executor object.

setExecutors

public void setExecutors(Map<String,Executor> executors)

setExecutors

Parameters:

executors - a Map object.