Routed Worker for bullmq
Worker extension for bullmq.
This worker allows you to register processors for specific job names within the queue. The example shows how this package is used.
bullmq is a peer dependency, you'll need to install it yourself.
Install
npm i @art-of-coding/routed-worker bullmq [--save]
Example
import RoutedWorker, {
Job
} from './index'
// create a new routed worker with the queue name 'Example'
const worker = new RoutedWorker('Example')
// Interface for job data
interface JobData {
name: string,
age: number
}
// Add a route, this is the job name (in this case, 'Greeting')
worker.on('Greeting', async (job: Job<JobData>) => {
// Do something and return a result
return `Hello, ${job.data.name}!`
})
// start the worker (required!)
worker.start()License
Copyright 2020 Art of Coding.
This software is licensed under the MIT License.
