import { Process, Processor } from '@nestjs/bull'; import { UserDeleteService } from './delete.service'; @Processor('user-delete') export class UserDeleteProcessor { constructor(private readonly userDeleteService: UserDeleteService) {} @Process('handle-delete-requests') public async handleDeleteRequests() { return await this.userDeleteService.handleDeleteRequests(); } }