Add Queue binding method to create event subscriptions at runtime #14733

jkahn117 · 2026-07-16T17:22:57Z

jkahn117
Jul 16, 2026

Current Behavior

Queue event subscriptions can only be created via the REST API (POST /accounts/{account_id}/event_subscriptions/subscriptions) or the wrangler queues subscription create CLI command. There is no way to create or manage subscriptions dynamically from within a Worker using the Queue binding.

Desired Behavior

Add a subscribe() method (and optionally unsubscribe()) to the Queue binding so that Workers can dynamically create event subscriptions at runtime:

await env.MY_QUEUE.subscribe({
  source: { type: "artifacts.repo" },
  events: ["pushed"],
  name: "my-artifacts-repo-subscription",
  enabled: true,
});

// Account-scoped Artifacts events:
await env.MY_QUEUE.subscribe({
  source: { type: "artifacts" },
  events: ["repo.created"],
});

// Cleanup:
await env.MY_QUEUE.unsubscribe("my-artifacts-repo-subscription");

Proposed Type Definitions (workers-sdk)

// partial list
type QueueEventSource =
  | { type: "artifacts" }
  | { type: "artifacts.repo" }
  | { type: "images" }
  | { type: "kv" }
  | { type: "r2" }
  | { type: "superSlurper" }
  | { type: "vectorize" }
  | { type: "workersAi.model"; model_name: string }
  | { type: "workersBuilds.worker"; worker_name: string }
  | { type: "workflows.workflow"; workflow_name: string };

interface QueueSubscriptionOptions {
  source: QueueEventSource;
  events: string[];
  name?: string;
  enabled?: boolean;
}

interface Queue<Body = unknown> {
  // existing methods...
  send(message: Body, options?: QueueSendOptions): Promise<QueueSendResponse>;
  sendBatch(
    messages: Iterable<MessageSendRequest<Body>>,
    options?: QueueSendBatchOptions,
  ): Promise<QueueSendBatchResponse>;
  metrics(): Promise<QueueMetrics>;

  // proposed
  subscribe(options: QueueSubscriptionOptions): Promise<void>;
  unsubscribe(name: string): Promise<void>;
}

API Reference

The underlying REST API already supports this via POST /accounts/{account_id}/event_subscriptions/subscriptions and DELETE /accounts/{account_id}/event_subscriptions/subscriptions/{subscription_id}. This feature would expose that capability through the binding.

Related

#14721 — CLI support for artifacts and artifacts.repo sources
https://developers.cloudflare.com/api/resources/queues/subresources/subscriptions/

Use Cases

Dynamic provisioning — Workers can set up subscriptions on startup or based on configuration without a separate deploy step or CLI command.
Self-service patterns — A Worker could manage subscriptions for multiple queues or sources based on runtime logic.

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Add Queue binding method to create event subscriptions at runtime #14733

Uh oh!

{{title}}

Uh oh!

Replies: 0 comments

Select a reply

Uh oh!

Uh oh!

Add Queue binding method to create event subscriptions at runtime #14733

Uh oh!

jkahn117 Jul 16, 2026

Replies: 0 comments

jkahn117
Jul 16, 2026