Processor

The Processor interface represents a job processor that can process jobs from the queue, either in the background or synchronously.

Methods

startInBackground

startInBackground(): void

Start the job processor in the background. This will run continuously and process jobs as they become available. It polls for new jobs every pollInterval milliseconds (default: 5 seconds).

stop

stop(): void

Stop the job processor that runs in the background.

isRunning

isRunning(): boolean

Check if the job processor is running.

start

start(): Promise<number>

Start the job processor synchronously. This will process jobs immediately and then stop. Returns the number of jobs processed.