bull-mqjob-queue-strategy.md 3.6 KB


title: "BullMQJobQueueStrategy" isDefaultIndex: false

generated: true

import MemberInfo from '@site/src/components/MemberInfo'; import GenerationInfo from '@site/src/components/GenerationInfo'; import MemberDescription from '@site/src/components/MemberDescription';

BullMQJobQueueStrategy

This JobQueueStrategy uses BullMQ to implement a push-based job queue on top of Redis. It should not be used alone, but as part of the BullMQJobQueuePlugin.

class BullMQJobQueueStrategy implements InspectableJobQueueStrategy {
    init(injector: Injector) => Promise<void>;
    destroy() => ;
    add(job: Job<Data>) => Promise<Job<Data>>;
    cancelJob(jobId: string) => Promise<Job | undefined>;
    findMany(options?: JobListOptions) => Promise<PaginatedList<Job>>;
    findManyById(ids: ID[]) => Promise<Job[]>;
    findOne(id: ID) => Promise<Job | undefined>;
    removeSettledJobs(queueNames?: string[], olderThan?: Date) => Promise<number>;
    start(queueName: string, process: (job: Job<Data>) => Promise<any>) => Promise<void>;
    stop(queueName: string, process: (job: Job<Data>) => Promise<any>) => Promise<void>;
}
### init Injector) => Promise<void>`} /> ### destroy `} /> ### add Job<Data>) => Promise<Job<Data>>`} /> ### cancelJob Promise<Job | undefined>`} /> ### findMany Promise<PaginatedList<Job>>`} /> ### findManyById ID[]) => Promise<Job[]>`} /> ### findOne ID) => Promise<Job | undefined>`} /> ### removeSettledJobs Promise<number>`} /> ### start Job<Data>) => Promise<any>) => Promise<void>`} /> ### stop Job<Data>) => Promise<any>) => Promise<void>`} />