public class PipelineExecutorTaskManagerImplHelper extends Object
Constructor and Description |
---|
PipelineExecutorTaskManagerImplHelper(javax.enterprise.inject.Instance<ConfigExecutor> configExecutorInstance,
javax.enterprise.inject.Instance<PipelineEventListener> pipelineEventListenerInstance) |
Modifier and Type | Method and Description |
---|---|
ExecutorService |
createExecutorService() |
List<PipelineEventListener> |
createExternalListeners() |
PipelineExecutor |
createPipelineExecutor() |
PipelineExecutorTaskImpl |
createTask(PipelineExecutorTaskDef taskDef) |
PipelineExecutorTaskImpl |
createTask(PipelineExecutorTaskDef taskDef,
String executionId) |
String |
generateTaskId() |
protected PipelineExecutor |
newPipelineExecutor(Collection<ConfigExecutor> configs)
added for testing/internal purposes, interested parties must use createPipelineExecutor()
|
void |
notifyExternalListeners(List<PipelineEventListener> externalListeners,
PipelineEvent event) |
void |
setTaskInStoppedStatus(PipelineExecutorTaskImpl task) |
public PipelineExecutorTaskManagerImplHelper(javax.enterprise.inject.Instance<ConfigExecutor> configExecutorInstance, javax.enterprise.inject.Instance<PipelineEventListener> pipelineEventListenerInstance)
public ExecutorService createExecutorService()
public PipelineExecutor createPipelineExecutor()
protected PipelineExecutor newPipelineExecutor(Collection<ConfigExecutor> configs)
public List<PipelineEventListener> createExternalListeners()
public void notifyExternalListeners(List<PipelineEventListener> externalListeners, PipelineEvent event)
public PipelineExecutorTaskImpl createTask(PipelineExecutorTaskDef taskDef)
public PipelineExecutorTaskImpl createTask(PipelineExecutorTaskDef taskDef, String executionId)
public String generateTaskId()
public void setTaskInStoppedStatus(PipelineExecutorTaskImpl task)
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.