@bullstudio/bullmq适应器

Bullstudio队列适配器,用于主机拥有的BullMQ队列.

当您的应用程序已经创建 BullMQ 时, 在嵌入式模式下使用此软件包 Queue 实例和您想要将选中队列显示为 Bullstudio 仪表板实例.

安装

pnpm add @bullstudio/bullmq-adapter

bullmq 是同级依赖。 公牛队使用队列实例和 Redis 由您的主机应用程序拥有的连接 .

使用量

import { createBullMqQueueAdapter } from "@bullstudio/bullmq-adapter";
import { Queue } from "bullmq";

const emailQueue = new Queue("email", {
  connection,
});

const emailQueueAdapter = createBullMqQueueAdapter(emailQueue, {
  key: "email",
  label: "Email",
});

将返回的队列适配器传递到框架适配器仪表板厂:

const dashboard = bullstudio({
  queues: [emailQueueAdapter],
});

选项

提供自定义 key 当多个提供的队列可以共享相同的队列时 名称或前缀.

能力

BullMQ 适配器支持队列检查,工作列表,工作细节,工作日志, 任务重试、去职、队列暂停和恢复、工人计数和BullMQ流量.

Bullstudio 不关闭所提供的队列或 Redis 连接 。 留着 您主机应用程序关闭路径中的生命周期 .