tasks-controller/org.artofdev.tasks.controller/TasksActor

TasksActor

@Service

class TasksActor(config: TaskControllerConfig, actorNet: IActorNet, taskRepo: TaskRepo, taskTypeRepo: TaskTypeRepo, pipelineTaskTypeRepo: PipelineTaskTypeRepo, errorRepo: ErrorRepo, transactionTemplate: TransactionTemplate, var executorRepo: ExecutorRepo, pluginManagerService: PluginManagerService, @Lazy taskServiceApi: TaskServiceApi, var executorTypeRepo: TaskExecutorTypeRepo, executionEngine: ExecutionEngine? = null) : SimpleThreadObject, TasksActorApi, TaskServiceBase

Constructors

constructor(config: TaskControllerConfig, actorNet: IActorNet, taskRepo: TaskRepo, taskTypeRepo: TaskTypeRepo, pipelineTaskTypeRepo: PipelineTaskTypeRepo, errorRepo: ErrorRepo, transactionTemplate: TransactionTemplate, executorRepo: ExecutorRepo, pluginManagerService: PluginManagerService, @Lazy taskServiceApi: TaskServiceApi, executorTypeRepo: TaskExecutorTypeRepo, executionEngine: ExecutionEngine? = null)

Types

object Companion

Properties

open override var executorRepo: ExecutorRepo

executorTypeRepo

open override var executorTypeRepo: TaskExecutorTypeRepo

Functions

createActorGroup

open override fun createActorGroup(address: ActorIdent)

open fun lookupExecutor(executorHid: String, executorTypeHid: String): Executor

open override fun onTaskEnded(task: TaskEntity)

fun run()

open override fun sendMessage(msg: Message, address: ActorIdent)

sendNotification

open override fun sendNotification(msg: Message)

sendNotifIfTaskFinished

open override fun sendNotifIfTaskFinished(task: TaskEntity)

sendPipelineControllerEvent

open override fun sendPipelineControllerEvent(event: PipelineControllerEvent, pipelineTaskHid: String)

@PreDestroy

fun start()

@EventListener(value = [ApplicationReadyEvent::class])

fun startActor()

fun waitForFinish()

waitUntilNotBusy

open override fun waitUntilNotBusy(timeoutMs: Long): Boolean