依赖项在 NestJS 处理器中未定义

问：

我已经在我的公牛中配置了队列机制，我可以轻松访问生产者发送的消息进行处理。我将使用此信息进行一些后台处理。

问题是，我有一些需要访问的服务和存储库，但似乎我无法访问。我在 NestJS 中编写了自定义使用者，我从应用程序中访问对象

await app.resolve<LoggerService>(LoggerService);

应用程序在哪里NestFastifyApplication

在 Bull 的情况下，构造函数注入不能直接在处理器中起作用。

export class PromotionProcessor {

    public constructor(private readonly serviceLayer: ServiceLayer) { }


    @Process(PACKAGE_PROMOTION)
    async processMtPackagePromotion(job: Job<PackagePromotionRequest>):Promise<void> {
        const { data } = job;
        const messageData = data as unknown as PromotionRequest; 
       await this.serviceLayer.promoteToNextLifecycle(messageData.data, messageData.reqData);
    }
}

如何在此处使用存储库和服务？

@Module({
  imports: [...APP_IMPORTS],
  controllers: [...APP_CONTROLLERS],
  providers: [...APP_PROVIDERS],
})

APP_IMPORTS具有 bull 配置，定义了所有存储库和服务APP_PROVIDERS

nestjs nestjsbull

import { Module } from '@nestjs/common';
import { BullModule } from '@nestjs/bull';
import { ServiceLayerModule } from '../../serviceLayer/serviceLayer.module.js';
import { PromotionProcessor } from './PromotionProcessor.service.js';

@Module({
    controllers: [],
    providers: [PromotionProcessor],
    imports: [
        BullModule.registerQueue({
            name: 'myQueueName',
        }),
        ServiceLayerModule,
    ],
})
export class PromotionProcessorModule {}

此外，还需要将导入到PromotionProcessorModuleAppModule

然后，在包含该文件的文件中，您应该能够将文件注入到构造函数中。PromotionProcessor

有时可能会有一些循环引用，这些引用也会提醒您，以便您可以进行显式注入如下所示：

import { Inject, forwardRef } from '@nestjs/common';
export class PromotionProcessor {

    public constructor( @Inject(forwardRef(() => ServiceLayer)) private readonly serviceLayer: ServiceLayer) { }


    @Process(PACKAGE_PROMOTION)
    async processMtPackagePromotion(job: Job<PackagePromotionRequest>):Promise<void> {
        const { data } = job;
        const messageData = data as unknown as PromotionRequest; 
       await this.serviceLayer.promoteToNextLifecycle(messageData.data, messageData.reqData);
    }
}

希望这在一定程度上有所帮助。

依赖项在 NestJS 处理器中未定义 - @nestjs/bull

Dependencies are undefined in NestJS processors - @nestjs/bull

评论

评论