Integrations

BullMQ Integration

Connect Queuedash to your BullMQ queues.

BullMQ is our recommended queue library. The SDK auto-detects BullMQ queues and starts syncing immediately.

Attach a queue

import { Queue } from "bullmq";
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", {
  connection: { host: "localhost", port: 6379 },
});
 
qd.attach(myQueue); // that's it

Multiple queues

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

Tracked events

  • added, waiting, delayed
  • active, progress
  • completed, failed, stalled
  • removed

Shutdown

The SDK handles shutdown automatically. You can also stop it manually:

// Flush remaining jobs and close connections
await qd.stop();

Next: configure the SDK and set up alerts.

ConfigurationBull