***
title: "DefaultJobQueuePlugin"
generated: true
---------------
## DefaultJobQueuePlugin
A plugin which configures Vendure to use the SQL database to persist the JobQueue jobs using the [SqlJobQueueStrategy](/current/core/reference/typescript-api/job-queue/sql-job-queue-strategy#sqljobqueuestrategy). If you add this
plugin to an existing Vendure installation, you'll need to run a [database migration](/current/core/developer-guide/migrations), since this
plugin will add a new "job\_record" table to the database.
*Example*
```ts
import { DefaultJobQueuePlugin, VendureConfig } from '@vendure/core';
export const config: VendureConfig = {
// Add an instance of the plugin to the plugins array
plugins: [
DefaultJobQueuePlugin,
],
};
```
## Configuration
It is possible to configure the behaviour of the [SqlJobQueueStrategy](/current/core/reference/typescript-api/job-queue/sql-job-queue-strategy#sqljobqueuestrategy) by passing options to the static `init()` function:
### pollInterval
The interval in ms between polling for new jobs. The default is 200ms.
Using a longer interval reduces load on the database but results in a slight
delay in processing jobs. For more control, it is possible to supply a function which can specify
a pollInterval based on the queue name:
*Example*
```ts
export const config: VendureConfig = {
plugins: [
DefaultJobQueuePlugin.init({
pollInterval: queueName => {
if (queueName === 'cart-recovery-email') {
// This queue does not need to be polled so frequently,
// so we set a longer interval in order to reduce load
// on the database.
return 10000;
}
return 200;
},
}),
],
};
```
### concurrency
The number of jobs to process concurrently per worker. Defaults to 1.
### backoffStrategy
Defines the backoff strategy used when retrying failed jobs. In other words, if a job fails
and is configured to be re-tried, how long should we wait before the next attempt?
By default, a job will be retried as soon as possible, but in some cases this is not desirable. For example,
a job may interact with an unreliable 3rd-party API which is sensitive to too many requests. In this case, an
exponential backoff may be used which progressively increases the delay between each subsequent retry.
*Example*
```ts
export const config: VendureConfig = {
plugins: [
DefaultJobQueuePlugin.init({
pollInterval: 5000,
concurrency: 2
backoffStrategy: (queueName, attemptsMade, job) => {
if (queueName === 'transcode-video') {
// exponential backoff example
return (attemptsMade ** 2) * 1000;
}
// A default delay for all other queues
return 1000;
},
setRetries: (queueName, job) => {
if (queueName === 'send-email') {
// Override the default number of retries
// for the 'send-email' job because we have
// a very unreliable email service.
return 10;
}
return job.retries;
}
}),
],
};
```
### Removing old jobs
Since v3.3, the job queue will automatically remove old jobs from the database. This is done by a scheduled task
which runs every 2 hours by default. The number of jobs to keep in the database can be configured using the
`keepJobsCount` option. The default is 1000.
*Example*
```ts
export const config: VendureConfig = {
plugins: [
DefaultJobQueuePlugin.init({
// The number of completed/failed/cancelled
// jobs to keep in the database. The default is 1000.
keepJobsCount: 100,
// The interval at which to run the clean-up task.
// This can be a standard cron expression or a function
// that returns a cron expression. The default is every 2 hours.
cleanJobsSchedule: cron => cron.every(5).hours(),
}),
],
};
```
```ts title="Signature"
class DefaultJobQueuePlugin {
init(options: DefaultJobQueueOptions) => Type;
}
```
## cleanJobsTask
A [ScheduledTask](/current/core/reference/typescript-api/scheduled-tasks/scheduled-task#scheduledtask) that cleans up old jobs from the database when using the DefaultJobQueuePlugin.
You can configure the settings & schedule of the task via the [DefaultJobQueuePlugin](/current/core/reference/typescript-api/job-queue/default-job-queue-plugin#defaultjobqueueplugin) options.
## DefaultJobQueueOptions
Configuration options for the DefaultJobQueuePlugin. These values get passed into the
[SqlJobQueueStrategy](/current/core/reference/typescript-api/job-queue/sql-job-queue-strategy#sqljobqueuestrategy).
```ts title="Signature"
interface DefaultJobQueueOptions {
pollInterval?: number | ((queueName: string) => number);
concurrency?: number | ((queueName: string) => number);
backoffStrategy?: BackoffStrategy;
setRetries?: (queueName: string, job: Job) => number;
useDatabaseForBuffer?: boolean;
gracefulShutdownTimeout?: number;
keepJobsCount?: number;
cleanJobsSchedule?: ScheduledTaskConfig['schedule'];
}
```
### pollInterval
\
number)`} default={`200`} />
The interval in ms between polling the database for new jobs. If many job queues
are active, the polling may cause undue load on the database, in which case this value
should be increased to e.g. 1000.
### concurrency
\ number)`} default={`1`} />
How many jobs from a given queue to process concurrently.
Can be set to a function which receives the queue name and returns
the concurrency limit. This is useful for limiting concurrency on
queues which have resource-intensive jobs.
*Example*
```ts
DefaultJobQueuePlugin.init({
concurrency: (queueName) => {
if (queueName === 'apply-collection-filters') {
return 1;
}
return 3;
}
})
```
### backoffStrategy
\BackoffStrategy`} default={`() => 1000`} />
The strategy used to decide how long to wait before retrying a failed job.
### setRetries
\Job) => number`} />
When a job is added to the JobQueue using `JobQueue.add()`, the calling
code may specify the number of retries in case of failure. This option allows
you to override that number and specify your own number of retries based on
the job being added.
*Example*
```ts
setRetries: (queueName, job) => {
if (queueName === 'send-email') {
// Override the default number of retries
// for the 'send-email' job because we have
// a very unreliable email service.
return 10;
}
return job.retries;
}
```
### useDatabaseForBuffer
\
If set to `true`, the database will be used to store buffered jobs. This is
recommended for production.
When enabled, a new `JobRecordBuffer` database entity will be defined which will
require a migration when first enabling this option.
### gracefulShutdownTimeout
\
The timeout in ms which the queue will use when attempting a graceful shutdown.
That means when the server is shut down but a job is running, the job queue will
wait for the job to complete before allowing the server to shut down. If the job
does not complete within this timeout window, the job will be forced to stop
and the server will shut down anyway.
### keepJobsCount
\
The number of completed/failed jobs to keep in the database. This is useful for
debugging and auditing purposes, but if you have a lot of jobs, it may be
desirable to limit the number of records in the database.
### cleanJobsSchedule
\ScheduledTaskConfig['schedule']`} default={`cron => cron.every(2).hours()`} since="3.3.0" />
The schedule for the "clean-jobs" task. This task will run periodically to clean up
old jobs from the database. The schedule can be a cron expression or a function
that returns a cron expression.