com.dtolabs.rundeck.core.execution.dispatch

Class OrchestratorNodeProcessor

java.lang.Object

com.dtolabs.rundeck.core.execution.dispatch.OrchestratorNodeProcessor

public class OrchestratorNodeProcessor
extends java.lang.Object

OrchestratorNodeProcessor is the class that deals with the concurrent processing of the jobs

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OrchestratorNodeProcessor.Entry
class	OrchestratorNodeProcessor.OrchestratorRunnable
static class	OrchestratorNodeProcessor.Result

Constructor Summary

Constructors

Constructor and Description
OrchestratorNodeProcessor(int threadCount, boolean keepgoing, Orchestrator orchestrator, java.util.Map<INodeEntry,java.util.concurrent.Callable<NodeStepResult>> executions)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	execute()
OrchestratorNodeProcessor.Entry	getCallable()

Methods inherited from class java.lang.Object

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

Constructor Detail

OrchestratorNodeProcessor

public OrchestratorNodeProcessor(int threadCount,
                         boolean keepgoing,
                         Orchestrator orchestrator,
                         java.util.Map<INodeEntry,java.util.concurrent.Callable<NodeStepResult>> executions)

Method Detail

execute

public boolean execute()
                throws java.util.concurrent.ExecutionException

Throws:

java.util.concurrent.ExecutionException

getCallable

public OrchestratorNodeProcessor.Entry getCallable()
                                            throws DispatcherException

Throws:

DispatcherException