integrationspackages/integrations/queue

queue package

Provider-agnostic queue — Upstash QStash (serverless) or BullMQ (self-host). Customers swap by env; application code stays the same.

Open docs

Stability: Stable
Scope: Global
Boundary: packages/integrations/queue
Owners: @nebutra/integrations

email247billing89ai-tasks14webhooks31

Status	Job	Queue	Attempts	Duration	When
Processing	job_9f3a2c	ai-tasks	1/3	412 ms	now
Success	job_8c41be	email	1/3	184 ms	12s ago
Success	job_77d019	billing	1/3	76 ms	48s ago
Failed	job_6b22f4	webhooks	3/3	5,012 ms	1m ago
Pending	job_5a18ee	email	2/3	—	2m ago
Success	job_4e0b7c	billing	1/3	221 ms	3m ago

Throughput

1,247

+8.2%

jobs/min

Success rate

99.4%

+0.3%

Last 60 min

Avg latency

184 ms

Healthy

Live · QStash / BullMQ

Usagequeue.ts

typescript

queue.ts

1import { getQueue, createJob } from "@nebutra/queue";
2
3// Auto-detects QStash, BullMQ, or memory from env.
4const queue = await getQueue();
5
6await queue.enqueue(
7  createJob("billing", "send-invoice", { orderId: order.id }, { tenantId }),
8);
9
10queue.registerHandler("billing", "send-invoice", async (job) => {
11  await sendInvoice(job.data.orderId);
12});

More in domain · integrationsView domain

admin-toolingPackage

packages/integrations/admin-tooling

Self-serve operator dashboards — tenants, billing overrides, feature-flag flips — all gated by @nebutra/permissions.

Explore

cachePackage

packages/integrations/cache

Tag-based cache with Redis, Upstash, or in-memory backend. Same get/set/invalidate(tags) for serverless and self-hosted.

Explore

collabPackage

packages/integrations/collab

Realtime co-editing primitives — Yjs CRDT, WebSocket transport, presence cursors. The piece every multi-user app eventually needs.

Explore

emailPackage

packages/integrations/email

Render React Email templates, dispatch through Resend / SES / SMTP. One sendEmail(template, props, recipient) for every transactional flow.

Explore

queue packagepackage

queue packagepackage

queue package

queue package