servers-executor/karya.servers.executor.usecase/ExecutorService

ExecutorService

class ExecutorService @Inject constructor(repoConnector: RepoConnector, config: ExecutorConfig, processMessage: ProcessMessage, producerClient: ProducerQueueClient, consumerClient: ConsumerQueueClient)

Service class responsible for managing the executor service.

Constructors

Link copied to clipboard
@Inject
constructor(repoConnector: RepoConnector, config: ExecutorConfig, processMessage: ProcessMessage, producerClient: ProducerQueueClient, consumerClient: ConsumerQueueClient)

Creates an instance of ExecutorService with the specified dependencies.

Types

Link copied to clipboard
object Companion : Logging

Functions

Link copied to clipboard
suspend fun start()

Starts the executor service by initializing the queue client and consuming messages.

Link copied to clipboard
fun stop()

Stops the executor service by shutting down the queue client, repository connector, and connectors.