Queue Events 리스너

Source URL: https://docs.bullmq.io/bullmq-pro/nestjs/queue-events-listeners

Queue Events 리스너

QueueEvents 인스턴스를 등록하려면 QueueEventsListener 데코레이터를 사용해야 합니다:

import {
  QueueEventsListener,
  QueueEventsHost,
  OnQueueEvent,
} from '@taskforcesh/nestjs-bullmq-pro';

@QueueEventsListener('queueName')
export class TestQueueEvents extends QueueEventsHost {
  @OnQueueEvent('completed')
  onCompleted({
    jobId,
  }: {
    jobId: string;
    returnvalue: string;
    prev?: string;
  }) {
    // do some stuff
  }
}

그런 다음 이를 provider로 등록합니다:

@Module({
  imports: [
    BullModule.registerQueue({
      name: 'queueName',
      connection: {
        host: '0.0.0.0',
        port: 6380,
      },
    }),
  ],
  providers: [TestQueueEvents],
})
export class AppModule {}

더 읽어보기:

• 💡 Queues Technique
• 💡 Register Queue API Reference
• 💡 Queue Events Pro Listener API Reference