@bullstudio/nestjs (英语)

雀巢JS框架适配器,用于Bulstudio嵌入模式.

安装

pnpm add @bullstudio/nestjs @bullstudio/bullmq-adapter

安装您已经使用的 Nest 平台 :

pnpm add @nestjs/common @nestjs/core @nestjs/platform-express

或:

pnpm add @nestjs/common @nestjs/core @nestjs/platform-fastify

用于RootAsync

使用 forRootAsync() 当队列由巢穴依赖注射提供时. 通过任何导出注入队列提供者的模块 imports。 。 。 .

import { createBullMqQueueAdapter } from "@bullstudio/bullmq-adapter";
import { BullstudioModule } from "@bullstudio/nestjs";
import { getQueueToken } from "@nestjs/bullmq";
import { Module } from "@nestjs/common";
import type { Queue } from "bullmq";

@Module({
  imports: [
    BullstudioModule.forRootAsync({
      imports: [QueueModule],
      inject: [getQueueToken("email")],
      useFactory: (emailQueue: Queue) => ({
        mountPath: "/ops/bullstudio",
        queues: [
          createBullMqQueueAdapter(emailQueue, {
            key: "email",
            label: "Email",
          }),
        ],
        readOnly: true,
      }),
    }),
  ],
})
export class AppModule {}

旋转

使用 forRoot() 当队列适配器可以直接创建时.

import { createBullMqQueueAdapter } from "@bullstudio/bullmq-adapter";
import { BullstudioModule } from "@bullstudio/nestjs";
import { Module } from "@nestjs/common";
import { Queue } from "bullmq";

const emailQueue = new Queue("email");

@Module({
  imports: [
    BullstudioModule.forRoot({
      mountPath: "/ops/bullstudio",
      queues: [
        createBullMqQueueAdapter(emailQueue, {
          key: "email",
          label: "Email",
        }),
      ],
      protection: {
        type: "basic",
        username: process.env.BULLSTUDIO_USERNAME ?? "operator",
        password: process.env.BULLSTUDIO_PASSWORD ?? "change-me",
      },
    }),
  ],
})
export class AppModule {}

mountPath 是公共仪表板 URL。 它直接挂在.. 基础快报或快报服务器,独立于 app.setGlobalPrefix()。 。 。 .

嵌入模式只显示配置中提供的队列适配器 . Bullstudio不创建队列,注册处理器,或自有队列生命周期.