Class TemporalWorkerManagerService

Temporal Worker Manager Service

Manages the lifecycle of Temporal workers including:

Worker initialization and configuration (single or multiple workers)
Activity discovery and registration
Worker health monitoring
Graceful shutdown handling with timeout protection
Support for multiple task queues
Proper process signal handling (SIGTERM/SIGINT)

Implements

OnModuleInit
OnModuleDestroy
OnApplicationBootstrap
BeforeApplicationShutdown

Constructors

constructor

new TemporalWorkerManagerService(
    discoveryService: TemporalDiscoveryService,
    options: TemporalOptions,
    injectedConnection: NativeConnection | null,
): TemporalWorkerManagerService
Parameters
- discoveryService: TemporalDiscoveryService
- options: TemporalOptions
- injectedConnection: NativeConnection | null
Returns TemporalWorkerManagerService
- Defined in src/services/temporal-worker.service.ts:63

Methods

beforeApplicationShutdown

beforeApplicationShutdown(signal?: string): Promise<void>
BeforeApplicationShutdown lifecycle hook Initiates graceful shutdown before the application fully shuts down This ensures workers have time to complete in-flight tasks
Parameters
- Optionalsignal: string
Returns Promise<void>
Implementation of BeforeApplicationShutdown.beforeApplicationShutdown
- Defined in src/services/temporal-worker.service.ts:188

getAllWorkers

getAllWorkers(): MultipleWorkersInfo
Get all workers information

Returns MultipleWorkersInfo
- Defined in src/services/temporal-worker.service.ts:374

getConnection

getConnection(): NativeConnection | null
Get the native connection for creating custom workers

Returns NativeConnection | null
NativeConnection instance or null
- Defined in src/services/temporal-worker.service.ts:579

getHealthStatus

getHealthStatus(): WorkerHealthStatus
Get worker health status

Returns WorkerHealthStatus
- Defined in src/services/temporal-worker.service.ts:959

getRegisteredActivities

getRegisteredActivities(): Record<string, Function>
Get registered activities

Returns Record<string, Function>
- Defined in src/services/temporal-worker.service.ts:888

getStats

getStats(): WorkerStats
Get worker statistics

Returns WorkerStats
- Defined in src/services/temporal-worker.service.ts:978

getWorker

getWorker(taskQueue: string): Worker | null
Get a specific worker by task queue
Parameters
- taskQueue: string
Returns Worker | null
- Defined in src/services/temporal-worker.service.ts:366

getWorkerStatus

getWorkerStatus(): WorkerStatus
Get worker status

Returns WorkerStatus
- Defined in src/services/temporal-worker.service.ts:867

getWorkerStatusByTaskQueue

getWorkerStatusByTaskQueue(taskQueue: string): WorkerStatus | null
Get worker status for a specific task queue
Parameters
- taskQueue: string
Returns WorkerStatus | null
- Defined in src/services/temporal-worker.service.ts:394

isWorkerAvailable

isWorkerAvailable(): boolean
Check if worker is available

Returns boolean
- Defined in src/services/temporal-worker.service.ts:945

isWorkerRunning

isWorkerRunning(): boolean
Check if worker is running

Returns boolean
- Defined in src/services/temporal-worker.service.ts:952

onApplicationBootstrap

onApplicationBootstrap(): Promise<void>
Returns Promise<void>
Implementation of OnApplicationBootstrap.onApplicationBootstrap
- Defined in src/services/temporal-worker.service.ts:143

onModuleDestroy

onModuleDestroy(): Promise<void>
Returns Promise<void>
Implementation of OnModuleDestroy.onModuleDestroy
- Defined in src/services/temporal-worker.service.ts:213

onModuleInit

onModuleInit(): Promise<void>
Returns Promise<void>
Implementation of OnModuleInit.onModuleInit
- Defined in src/services/temporal-worker.service.ts:96

registerActivitiesFromDiscovery

registerActivitiesFromDiscovery(): Promise<ActivityRegistrationResult>
Register activities from discovery service

Returns Promise<ActivityRegistrationResult>
- Defined in src/services/temporal-worker.service.ts:899

registerWorker

registerWorker(workerDef: WorkerDefinition): Promise<CreateWorkerResult>
Register and create a new worker dynamically at runtime
Parameters
- workerDef: WorkerDefinition
Returns Promise<CreateWorkerResult>
- Defined in src/services/temporal-worker.service.ts:329

restartWorker

restartWorker(): Promise<WorkerRestartResult>
Restart the worker

Returns Promise<WorkerRestartResult>
- Defined in src/services/temporal-worker.service.ts:836

shutdown

shutdown(): Promise<void>
Shutdown the worker (alias for shutdownWorker)

Returns Promise<void>
- Defined in src/services/temporal-worker.service.ts:829

startWorker

startWorker(): Promise<void>
Start the worker

Returns Promise<void>
- Defined in src/services/temporal-worker.service.ts:658

startWorkerByTaskQueue

startWorkerByTaskQueue(taskQueue: string): Promise<void>
Start a specific worker by task queue
Parameters
- taskQueue: string
Returns Promise<void>
- Defined in src/services/temporal-worker.service.ts:402

stopWorker

stopWorker(): Promise<void>
Stop the worker gracefully

Returns Promise<void>
- Defined in src/services/temporal-worker.service.ts:806

stopWorkerByTaskQueue

stopWorkerByTaskQueue(taskQueue: string): Promise<void>
Stop a specific worker by task queue
Parameters
- taskQueue: string
Returns Promise<void>
- Defined in src/services/temporal-worker.service.ts:438