Skip to content

RabbitSubscribe method is loading before my constructor  #899

Open
@laxmaneasecommerce

Description

@laxmaneasecommerce

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

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions