diff --git a/backend/services/transfer-service/src/infrastructure/kafka/outbox-publisher.service.ts b/backend/services/transfer-service/src/infrastructure/kafka/outbox-publisher.service.ts index 02f4f828..7d1a1db2 100644 --- a/backend/services/transfer-service/src/infrastructure/kafka/outbox-publisher.service.ts +++ b/backend/services/transfer-service/src/infrastructure/kafka/outbox-publisher.service.ts @@ -27,11 +27,11 @@ export class OutboxPublisherService implements OnModuleInit, OnModuleDestroy { private readonly outboxRepository: OutboxRepository, private readonly configService: ConfigService, ) { - this.pollIntervalMs = this.configService.get('OUTBOX_POLL_INTERVAL_MS', 1000); - this.batchSize = this.configService.get('OUTBOX_BATCH_SIZE', 100); - this.cleanupIntervalMs = this.configService.get('OUTBOX_CLEANUP_INTERVAL_MS', 3600000); - this.confirmationTimeoutMinutes = this.configService.get('OUTBOX_CONFIRMATION_TIMEOUT_MINUTES', 5); - this.timeoutCheckIntervalMs = this.configService.get('OUTBOX_TIMEOUT_CHECK_INTERVAL_MS', 60000); + this.pollIntervalMs = Number(this.configService.get('OUTBOX_POLL_INTERVAL_MS', 1000)); + this.batchSize = Number(this.configService.get('OUTBOX_BATCH_SIZE', 100)); + this.cleanupIntervalMs = Number(this.configService.get('OUTBOX_CLEANUP_INTERVAL_MS', 3600000)); + this.confirmationTimeoutMinutes = Number(this.configService.get('OUTBOX_CONFIRMATION_TIMEOUT_MINUTES', 5)); + this.timeoutCheckIntervalMs = Number(this.configService.get('OUTBOX_TIMEOUT_CHECK_INTERVAL_MS', 60000)); } async onModuleInit() {