workbench

npm i @getworkbench/hono bullmq hono

import { Hono } from "hono";
import { Queue } from "bullmq";
import { workbench } from "@getworkbench/hono";

const app = new Hono();
const emailQueue = new Queue("email", { connection: { url: process.env.REDIS_URL! } });

app.route("/jobs", workbench({ queues: [emailQueue] }));

export default app;

bun add @getworkbench/elysia bullmq elysia

import { Elysia } from "elysia";
import { Queue } from "bullmq";
import { workbench } from "@getworkbench/elysia";

const emailQueue = new Queue("email", { connection: { url: process.env.REDIS_URL! } });

new Elysia()
  .mount("/jobs", workbench({ queues: [emailQueue], basePath: "/jobs" }))
  .listen(3000);

npm i @getworkbench/express bullmq express

import express from "express";
import { Queue } from "bullmq";
import { workbench } from "@getworkbench/express";

const app = express();
const emailQueue = new Queue("email", { connection: { url: process.env.REDIS_URL! } });

app.use("/jobs", workbench({ queues: [emailQueue] }));
app.listen(3000);

npm i @getworkbench/fastify bullmq fastify

import Fastify from "fastify";
import { Queue } from "bullmq";
import { workbench } from "@getworkbench/fastify";

const app = Fastify();
const emailQueue = new Queue("email", { connection: { url: process.env.REDIS_URL! } });

await app.register(workbench({ queues: [emailQueue] }), { prefix: "/jobs" });
await app.listen({ port: 3000 });

npm i @getworkbench/nestjs bullmq

import { NestFactory } from "@nestjs/core";
import { Queue } from "bullmq";
import { workbench } from "@getworkbench/nestjs";
import { AppModule } from "./app.module";

async function bootstrap() {
  const app = await NestFactory.create(AppModule);

  const emailQueue = new Queue("email", { connection: { url: process.env.REDIS_URL! } });

  await workbench(app, "/jobs", { queues: [emailQueue] });

  await app.listen(3000);
}
bootstrap();

Works on both the Express (default) and Fastify NestJS platforms.

npm i @getworkbench/adonis bullmq @adonisjs/core

// start/routes.ts
import router from "@adonisjs/core/services/router";
import { Queue } from "bullmq";
import { mountWorkbench } from "@getworkbench/adonis";

const emailQueue = new Queue("email", { connection: { url: process.env.REDIS_URL! } });

mountWorkbench(router, "/jobs", { queues: [emailQueue] });

Works with AdonisJS 6 and 7. See examples/with-adonis.

npm i @getworkbench/next bullmq

// app/jobs/[[...workbench]]/route.ts
import { Queue } from "bullmq";
import { workbench } from "@getworkbench/next";

const emailQueue = new Queue("email", { connection: { url: process.env.REDIS_URL! } });

export const { GET, POST, PUT, PATCH, DELETE } = workbench({
  queues: [emailQueue],
  basePath: "/jobs",
});

Next doesn’t host BullMQ workers itself — run them in a sibling process. See examples/with-next.

npm i @getworkbench/tanstack-start bullmq @tanstack/react-start

// src/lib/workbench-handlers.ts
import { Queue } from "bullmq";
import { workbench } from "@getworkbench/tanstack-start";

const emailQueue = new Queue("email", { connection: { url: process.env.REDIS_URL! } });

export const workbenchHandlers = workbench({
  queues: [emailQueue],
  basePath: "/jobs",
});

// src/routes/jobs.ts
import { createFileRoute } from "@tanstack/react-router";
import { workbenchHandlers } from "../lib/workbench-handlers";

export const Route = createFileRoute("/jobs")({
  server: { handlers: workbenchHandlers },
});

// src/routes/jobs/$.ts
import { createFileRoute } from "@tanstack/react-router";
import { workbenchHandlers } from "../../lib/workbench-handlers";

export const Route = createFileRoute("/jobs/$")({
  server: { handlers: workbenchHandlers },
});

Register handlers on both /jobs and /jobs/$ so the bare mount and nested paths work. TanStack Start doesn’t host BullMQ workers itself — run them in a sibling process. See examples/with-tanstack-start.

npm i @getworkbench/koa bullmq koa

import Koa from "koa";
import { Queue } from "bullmq";
import { workbench } from "@getworkbench/koa";

const app = new Koa();
const emailQueue = new Queue("email", { connection: { url: process.env.REDIS_URL! } });

app.use(workbench({ queues: [emailQueue], basePath: "/jobs" }));
app.listen(3000);

Koa has no built-in mount helper — pass basePath so the middleware can match its own prefix and forward everything else to the next middleware.

npm i @getworkbench/astro bullmq

// src/pages/jobs/[...workbench].ts
import { Queue } from "bullmq";
import { workbench } from "@getworkbench/astro";

const emailQueue = new Queue("email", { connection: { url: process.env.REDIS_URL! } });

export const { GET, POST, PUT, PATCH, DELETE, prerender } = workbench({
  queues: [emailQueue],
  basePath: "/jobs",
});

Astro must be in server output mode (output: "server" or "hybrid"). Astro doesn’t host BullMQ workers itself — run them in a sibling process. See examples/with-astro.

npm i @getworkbench/nuxt bullmq

// server/routes/jobs/[...].ts
import { Queue } from "bullmq";
import { workbench } from "@getworkbench/nuxt";

const emailQueue = new Queue("email", { connection: { url: process.env.REDIS_URL! } });

export default workbench({
  queues: [emailQueue],
  basePath: "/jobs",
});

Nuxt’s server runtime (Nitro / h3) doesn’t host BullMQ workers itself — run them in a sibling process. See examples/with-nuxt.

bun add @getworkbench/bun bullmq

import { Queue } from "bullmq";
import { workbench } from "@getworkbench/bun";

const emailQueue = new Queue("email", { connection: { url: process.env.REDIS_URL! } });

const handler = workbench({ queues: [emailQueue], basePath: "/jobs" });

Bun.serve({
  port: 3000,
  fetch(req) {
    return handler(req, () => new Response("home"));
  },
});

npm i @getworkbench/h3 bullmq h3

import { createServer } from "node:http";
import { createApp, createRouter, toNodeListener } from "h3";
import { Queue } from "bullmq";
import { workbench } from "@getworkbench/h3";

const emailQueue = new Queue("email", { connection: { url: process.env.REDIS_URL! } });

const handler = workbench({ queues: [emailQueue], basePath: "/jobs" });

const router = createRouter().use("/jobs", handler).use("/jobs/**", handler);
const app = createApp().use(router);

createServer(toNodeListener(app)).listen(3000);

h3’s ** only matches one-or-more sub-segments, so register the handler at both /jobs and /jobs/**.