A powerful and type-safe job queue system for AdonisJS 6 applications. Built on top of BullMQ, it provides a clean API for managing background jobs, scheduled tasks, and complex job workflows.
Features:
- Clean BullMQ Integration
- Dedicated Ace commands for job management
- Scheduled and delayed job execution
- Flows: chains and complex workflows
- Observability with built-in metrics and Opentelemetry support
- QueueDash integration
Tip
For complete documentation, examples, and guides, visit: https://adonis-jobs.nemo.engineering
node ace configure @nemoventures/adonis-jobsCreate your first job:
import { Job } from '@nemoventures/adonis-jobs'
type SendEmailJobData = {
email: string
subject: string
}
export default class SendEmailJob extends Job<SendEmailJobData, void> {
async process(): Promise<void> {
// Send email logic here
}
}Dispatch it:
await SendEmailJob.dispatch({
email: '[email protected]',
subject: 'Welcome!'
})And run your worker:
node ace queue:workMIT