Integrations

Bee-Queue Integration

Connect Queuedash to your Bee-Queue queues.

Bee-Queue is a lightweight Redis queue. The SDK needs Bee-Queue 1 or later and recognizes a Bee-Queue queue when you attach it.

Attach a queue

import Queue from "bee-queue";
import { Queuedash } from "@queuedash/sdk";
 
const qd = new Queuedash({
  apiKey: process.env.QUEUEDASH_API_KEY,
});
 
// Initialize your queue and attach it
const myQueue = new Queue("my-queue", {
  redis: { host: "localhost", port: 6379 },
});
 
qd.attach(myQueue);

Bee-Queue emits the events below only in the process that calls queue.process(), so attach the queue there.

Multiple queues

import Queue from "bee-queue";
import { Queuedash } from "@queuedash/sdk";
 
const redis = { host: "localhost", port: 6379 };
 
const qd = new Queuedash({
  apiKey: process.env.QUEUEDASH_API_KEY,
});
 
qd.attach(new Queue("emails", { redis }));
qd.attach(new Queue("reports", { redis }));
qd.attach(new Queue("notifications", { redis }));

Tracked events

  • succeeded
  • failed
  • retrying

What's recorded

  • A job is sent when it succeeds, fails, or is retried, not when it's added or starts
  • Every Bee-Queue job is named default
  • The SDK records when a job finished but not when it started, so run times, stuck-job alerts, and processing-time alerts have nothing to measure
BullMonitoring