From f55ea5b73119e472ec291c44a570af370e1c1372 Mon Sep 17 00:00:00 2001 From: jos3duardo Date: Sun, 17 Aug 2025 15:23:35 -0400 Subject: [PATCH] Reduce DB pool size, payment concurrency, and job attempts --- src/modules/database/database.module.ts | 2 +- src/modules/payments/processor/payment.processor.ts | 2 +- src/modules/queue/queue.service.ts | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/modules/database/database.module.ts b/src/modules/database/database.module.ts index 37b516a..0823804 100644 --- a/src/modules/database/database.module.ts +++ b/src/modules/database/database.module.ts @@ -16,7 +16,7 @@ import { Payment } from '../payments/entities/payment.entity'; database: configService.get('database.database'), entities: [Payment], extra: { - max: 10, + max: 5, // connectionTimeoutMillis: 3000, }, synchronize: false, diff --git a/src/modules/payments/processor/payment.processor.ts b/src/modules/payments/processor/payment.processor.ts index 2c31d41..166029e 100644 --- a/src/modules/payments/processor/payment.processor.ts +++ b/src/modules/payments/processor/payment.processor.ts @@ -8,7 +8,7 @@ import { Payment } from '../entities/payment.entity'; import { Repository } from 'typeorm'; import { CreatePaymentDto } from '../dto/create-payment.dto'; -@Processor(PAYMENT_QUEUE, { concurrency: 10 }) +@Processor(PAYMENT_QUEUE, { concurrency: 5 }) @Injectable() export class PaymentProcessor extends WorkerHost { private readonly logger = new Logger(PaymentProcessor.name); diff --git a/src/modules/queue/queue.service.ts b/src/modules/queue/queue.service.ts index 06f678e..4e41ce0 100644 --- a/src/modules/queue/queue.service.ts +++ b/src/modules/queue/queue.service.ts @@ -11,7 +11,7 @@ export class QueueService { async addPaymentJob(data: CreatePaymentDto): Promise { await this.paymentQueue.add(PAYMENT_QUEUE, data, { jobId: data.correlationId, - attempts: 100, + attempts: 90, backoff: { type: 'exponential', delay: 100,