BullMQ
Search
⌃K

Queue Events Listeners

To register a QueueEvents instance, you need to use the QueueEventsListener decorator:
import {
QueueEventsListener,
QueueEventsHost,
OnQueueEvent,
} from '@nestjs/bullmq';
​
@QueueEventsListener('queueName')
export class TestQueueEvents extends QueueEventsHost {
@OnQueueEvent('completed')
onCompleted({
jobId,
}: {
jobId: string;
returnvalue: string;
prev?: string;
}) {
// do some stuff
}
}
And then register it as a provider:
@Module({
imports: [
BullModule.registerQueue({
name: 'queueName',
connection: {
host: '0.0.0.0',
port: 6380,
},
}),
],
providers: [TestQueueEvents],
})
export class AppModule {}

Read more:

Copyright (c) Taskforce.sh Inc.