@rlanz/bull-queue
is a queue system based on BullMQ
for AdonisJS.
[!NOTE] You must have a Redis server running on your machine.
This package is available in the npm registry.
node ace add @rlanz/bull-queue
The queue
service gives you access to the dispatch
method.
It will dispatch the linked job to the queue with the given payload.
import queue from '@rlanz/bull-queue/services/main';
queue.dispatch(RegisterStripeCustomer, {...});
// You can also specify options for a specific job
queue.dispatch(RegisterStripeCustomer, {...}, {
queueName: 'stripe',
});
You can create a job by running node ace make:job {job}
.
This will create the job within your app/jobs
directory.
The handle
method is what gets called when the jobs is processed while
the rescue
method is called when the max attempts of the job has been reached.
You can remove the rescue
method if you want.
Since the job instance is passed to the constructor, you can easily send notifications with the rescue
method. See this page for full documentation on the job instance.
Example job file:
// app/jobs/register_stripe_customer.ts
import { Job } from '@rlanz/bull-queue'
interface RegisterStripeCustomerPayload {
userId: string;
};
export default class RegisterStripeCustomer extends Job {
static get $$filepath() {
return import.meta.url
}
public async handle(payload: RegisterStripeCustomerPayload) {
// ...
}
/**
* This is an optional method that gets called if it exists when the retries has exceeded and is marked failed.
*/
public async rescue(payload: RegisterStripeCustomerPayload, error: Error) {}
}
By default, all jobs have a retry of 3 and this is set within your config/queue.ts
under the jobs
object.
You can also set the attempts on a call basis by passing the override as shown below:
queue.dispatch(SomeJob, {...}, { attempts: 3 })
If you need to add delays between retries, you can either set it globally via by adding this to your config/queue.ts
:
// config/queue.ts
import { defineConfig } from '@rlanz/bull-queue'
export default defineConfig({
// ...
jobs: {
attempts: 3,
backoff: {
type: 'exponential',
delay: 5000,
}
}
})
Or... you can also do it per job:
queue.dispatch(Somejob, {...}, {
attempts: 3,
backoff: { type: 'exponential', delay: 5000 }
})
With that configuration above, BullMQ will first add a 5s delay before the first retry, 20s before the 2nd, and 40s for the 3rd.
You can visit this page on further explanation / other retry options.
Run the queue worker with the following ace command:
node ace queue:listen
# or
node ace queue:listen --queue=stripe
# or
node ace queue:listen --queue=stripe,cloudflare
Once done, you will see the message Queue processing started
.