Class: ExecutableWorkerService
Defined in: packages/microservice/job-broker/src/executable/services/executable-worker.service.ts:20
Service for executing tasks received from the initial executable task queue. This service connects to RabbitMQ, consumes tasks, executes them, and sends the results to a specified storage queue.
Implements
OnApplicationBootstrap
Constructors
Constructor
new ExecutableWorkerService(
configSvc):ExecutableWorkerService
Defined in: packages/microservice/job-broker/src/executable/services/executable-worker.service.ts:27
Construct the worker with configuration service for RabbitMQ connectivity and queue settings.
Parameters
configSvc
ConfigService
Nest ConfigService used to resolve RabbitMQ URL, queue names, TTLs, and related options.
Returns
ExecutableWorkerService
Methods
onApplicationBootstrap()
onApplicationBootstrap():
Promise<void>
Defined in: packages/microservice/job-broker/src/executable/services/executable-worker.service.ts:63
This method is automatically called when the application is bootstrapped and sets up the RabbitMQ connection and starts consuming executable tasks.
Returns
Promise<void>
Implementation of
OnApplicationBootstrap.onApplicationBootstrap