diff --git a/packages/application-generic/src/health/queue-health-indicator.service.ts b/packages/application-generic/src/health/queue-health-indicator.service.ts index 0c23216d091..a64e8006939 100644 --- a/packages/application-generic/src/health/queue-health-indicator.service.ts +++ b/packages/application-generic/src/health/queue-health-indicator.service.ts @@ -14,7 +14,7 @@ export abstract class QueueHealthIndicator implements IHealthIndicator { constructor( - private queueBaseService: QueueBaseService, + private queueService: QueueBaseService, private indicatorKey: string, private serviceName: string, private logContext: string @@ -31,7 +31,7 @@ export abstract class QueueHealthIndicator } async handleHealthCheck(checkActive = false) { - const isReady = this.queueBaseService.isReady(); + const isReady = this.queueService.isReady(); if (!isReady) { Logger.verbose(`${this.serviceName} is not ready`, this.logContext); @@ -48,7 +48,7 @@ export abstract class QueueHealthIndicator return this.getStatus(this.indicatorKey, true); } - const isPaused = await this.queueBaseService.isPaused(); + const isPaused = await this.queueService.isPaused(); const isActive = isReady && !isPaused; if (!isActive) {