Open
Description
I am using below service to consume my queue
import { Controller } from '@nestjs/common';
import {
RabbitSubscribe, defaultNackErrorHandler,
} from '@golevelup/nestjs-rabbitmq';
import { WebhookRabbitMqListener } from 'commerce-library';
import { QueueService } from './service/queue.service';
@Controller()
export class QueueMessageConsumer {
constructor(private readonly warehouseService: QueueService
) { }
@RabbitSubscribe({
queue: 'V2webhook_queue',
queueOptions: {
durable: true
},
errorHandler: defaultNackErrorHandler,
})
async webhookV2EventsQueue({ data }: { data: WebhookRabbitMqListener }): Promise<any> {
try {
await this.warehouseService.processWebhookMessageQueue(data, 'V2webhook_queue')
} catch (error) {
console.log(error);
}
}
}
I am getting warehouseService is undefine in
the webhookV2EventsQueue
please help me
I am stuck