diff --git a/src/modules/queue/queue.service.ts b/src/modules/queue/queue.service.ts index e92eae9..b391be5 100644 --- a/src/modules/queue/queue.service.ts +++ b/src/modules/queue/queue.service.ts @@ -5,9 +5,8 @@ import { CreatePaymentDto } from '../payments/dto/create-payment.dto'; import { PAYMENT_QUEUE } from './constants/queue.constants'; export interface PaymentJobData { - paymentId: string; paymentData: CreatePaymentDto; - retryCount?: number; + createdAt: Date; } @Injectable() @@ -16,29 +15,13 @@ export class QueueService { async addPaymentJob(data: PaymentJobData): Promise { await this.paymentQueue.add(PAYMENT_QUEUE, data, { - attempts: 3, + attempts: 2, backoff: { type: 'exponential', delay: 2000, }, - removeOnComplete: 10, - removeOnFail: 5, - }); - } - - async addRetryPaymentJob( - data: PaymentJobData, - delay: number = 5000, - ): Promise { - await this.paymentQueue.add('process-payment', data, { - delay, - attempts: 2, - backoff: { - type: 'exponential', - delay: 3000, - }, - removeOnComplete: 10, - removeOnFail: 5, + removeOnComplete: 3, + removeOnFail: 2, }); } }