servers-executor/karya.servers.executor.usecase.external/ProcessExecutorMessage

ProcessExecutorMessage

class ProcessExecutorMessage @Inject constructor(queueClient: ProducerQueueClient, plansRepo: PlansRepo, processTask: ProcessTask, triggerHook: TriggerHook, getConnector: GetConnector)

Use case class responsible for processing executor messages.

Constructors

Link copied to clipboard
@Inject
constructor(queueClient: ProducerQueueClient, plansRepo: PlansRepo, processTask: ProcessTask, triggerHook: TriggerHook, getConnector: GetConnector)

Creates an instance of ProcessExecutorMessage with the specified dependencies.

Types

Link copied to clipboard
object Companion : Logging

Functions

Link copied to clipboard
suspend fun invoke(message: QueueMessage.ExecutorMessage)

Processes the executor message.