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);