Durable Message Delivery

Message Queue Built for Developers

Reliable webhook delivery, scheduled jobs, and background task processing with automatic retries and a powerful SDK.

Publish a message

curl -X POST "https://api.queuebear.com/v1/projects/proj_xxx/publish" \
  -H "Authorization: Bearer qb_live_xxxxx" \
  -H "Content-Type: application/json" \
  -d '{"destination": "https://api.example.com/webhook", "body": {"event": "user.created"}, "delay": "30s", "retries": 5}'

Everything You Need

A complete message queue solution with all the features you'd expect from a managed service.

Publish Messages

Send HTTP requests to any destination with configurable delays, retries, and callback URLs.

Cron Schedules

Create recurring jobs with full cron expression support and timezone handling.

Dead Letter Queue

Automatic DLQ for failed messages with easy retry capabilities and failure tracking.

Automatic Retries

Exponential backoff with configurable retry attempts ensures your messages always get delivered.

Multi-Project Support

Organize workloads across multiple projects with separate API keys and isolated queues.

Web Dashboard

UI for managing projects, monitoring messages, and debugging deliveries.

How It Works

Simple, reliable message delivery in three steps.

Publish

Send a message to QueueBear with your destination URL, delay settings, and retry configuration.

Deliver

QueueBear delivers your message to the destination with automatic retries using exponential backoff.

Track

Monitor delivery status, view logs, and handle failures through the dashboard or API.

TypeScript SDK

First-class TypeScript support with a clean, intuitive API for all QueueBear features.

npm install queuebear

Publish webhooks with retries and delays

import { QueueBear } from "queuebear";

const qb = new QueueBear({
  apiKey: "qb_live_xxx",
  projectId: "proj_xxx",
});

// Publish a message with delay and retries
const { messageId } = await qb.messages.publish(
  "https://api.example.com/webhook",
  { event: "user.created", userId: "123" },
  {
    delay: "30s",
    retries: 5,
    callbackUrl: "https://api.example.com/callback",
  }
);

// Check delivery status
const message = await qb.messages.get(messageId);
console.log(message.status); // "completed"

Cron-based recurring jobs

import { QueueBear } from "queuebear";

const qb = new QueueBear({
  apiKey: "qb_live_xxx",
  projectId: "proj_xxx",
});

// Create a daily schedule at 9 AM Eastern
const schedule = await qb.schedules.create({
  destination: "https://api.example.com/daily-report",
  cron: "0 9 * * *",
  timezone: "America/New_York",
  body: JSON.stringify({ type: "daily" }),
});

// Pause / Resume
await qb.schedules.pause(schedule.scheduleId);
await qb.schedules.resume(schedule.scheduleId);

Manage failed messages

import { QueueBear } from "queuebear";

const qb = new QueueBear({
  apiKey: "qb_live_xxx",
  projectId: "proj_xxx",
});

// List failed messages
const { entries } = await qb.dlq.list();

for (const entry of entries) {
  console.log(`Failed: ${entry.destination}`);
}

// Retry a failed message
const { newMessageId } = await qb.dlq.retry(entries[0].id);

// Or retry all / purge
await qb.dlq.retryAll();
await qb.dlq.purge();

Durable workflows with automatic step caching

import { QueueBear, serve } from "queuebear";

// 1. Define a workflow endpoint
export const POST = serve(async (context) => {
  const { userId, email } = context.input;

  await context.run("send-welcome", async () => {
    await sendEmail(email, "welcome");
  });

  await context.sleep("wait-3-days", 60 * 60 * 24 * 3);

  await context.run("send-followup", async () => {
    await sendEmail(email, "tips");
  });

  return { completed: true };
});

// 2. Trigger the workflow
const qb = new QueueBear({ apiKey: "qb_live_xxx", projectId: "proj_xxx" });

const { runId } = await qb.workflows.trigger(
  "user-onboarding",
  "https://your-app.com/api/workflows/onboarding",
  { userId: "123", email: "[email protected]" }
);

Ready to Get Started?

Deploy QueueBear in minutes and take control of your message queue infrastructure.

Open Dashboard API Reference