How to get QueueEvents in NestJS

[BITRU]

I am trying to return result from service. I have this code working but its looks ugly and wrong.
But can't figure out now in Nestjs get QueueEvents correct way.

import { BullModule } from '@nestjs/bullmq
import { Module } from "@nestjs/common;
import { BullProcessor } from ./bull.processor';
import { BullService } from /bull.service'

@Module ({
     exports: [BullService], 
     imports: [
               BullModule. forRoot ( connection: host: 10.73.0.1, port: 6379}),
               BullModule.registerFlowProducer({name: 'service-queue'}),
     controllers: [],
     providers: [BullService, BullProcessor],
})
export class BullMQModule {}

import { Injectable } from '@nestjs/common';

import { InjectFlowProducer } from *@nestjs/bullmg
import { QueueEvents, FlowProducer } from bullmq
@Injectable() 
export class BullService {
  constructor (
     @InjectFlowProducer ('service-queue') private fooFlowProducer: FlowProducer,) {}

async addToQue (payload) {
    const job = await this.fooFlowProducer .add({name: 'service-queue', queueName: 'service-queue data: payload,})

    const result = await job. job.waitUntilFinished( 
                      new QueueEvents ('service-queue', { connection: {  host: '10.73.0.1', port: 6379} })

     return result;
}}

So my question is how to get QueueEvents in NestJS?

[yaroslav-ilin]

Has anyone figured that out?

[elovin]

I think you have to either use the NestJS Integration or your own wrappers around BullMQ and not mix them.

For the NestJS integration you can use the QueueEventsListener decorator.

[elovin]

Also see the example here:
https://github.com/njgerner/nestjs-bullmq-example/tree/master