Cloudflare Queues

cloudflareQueuecloudflare-queues

Global at-least-once message queue consumed by Workers, with batching and dead letter queues.

Provider
cloudflare
Kind
Queue
Category
Messaging
Properties · 9 set by this component
propertytypevaluesrequiredkind defaultthis component
backoffenumnone | fixed | exponential | exponential-jitterno—inherited
consumerType · component propertyenumpush | pullnopushinherited
deadLetterQueueboolean—nofalse▸ false
deliveryenumat-most-once | at-least-once | exactly-onceyes—▸ at-least-once
instancesinteger—no—inherited
managedboolean—nofalse▸ true
maxAttemptsinteger—no—▸ 3
maxBatchSize · component propertyinteger—no100inherited
maxConsumerConcurrency · component propertyinteger—no250inherited
maxMessageSizeKb · component propertyinteger—no128inherited
maxRetentionDays · component propertyinteger—no14inherited
orderingenumnone | per-key | globalnonone▸ none
persistenceboolean—notrue▸ true
replayboolean—nofalse▸ false
retentionDaysinteger—no—▸ 1
roleenumwork | dlq | retry | offline-mailbox | frontiernowork▸ work
Rules that apply · 3

Every rule whose selector covers this component's kind or its category. Whether a rule fires depends on the design: its properties, its edges and its groups.

queue-missing-dlq

A queue that receives asynchronous traffic and has no dead-letter queue either drops poison messages or retries them forever. Neither outcome leaves anything for a human to investigate.

  • — all of these hold:
  • — the node's `deadLetterQueue` is false
  • — the node has at least one asynchronous incoming edge
retry-queue-without-dlq

A retry queue is where poison messages end up. With no dead-letter queue they are retried forever or dropped in silence, and nobody ever looks at the failed payment.

  • — all of these hold:
  • — the node's `role` is "retry"
  • — the node's `deadLetterQueue` is false
retry-without-backoff

Retrying a transient failure at full speed turns one slow dependency into a retry storm. A retry queue backs off, preferably exponentially and with jitter.

  • — all of these hold:
  • — the node's `role` is "retry"
  • — any of these hold:
  • — the node's `backoff` has no value
  • — the node's `backoff` is "none"
Use it in a design
nodes:
  - { id: "queues", component: "cloudflare-queues" }
Other Queue products · 23
Source
# yaml-language-server: $schema=../../schema/component.schema.json
# Cloudflare Queues: a global message queue consumed by Workers. "Delivery guarantees" states at
# least once delivery; "Queues - Limits" gives the 24 hour default retention (up to 14 days) and the
# 100 message batch, and "Dead letter queues" states no DLQ is attached until one is configured.
schemaVersion: "1"
type: "component"
id: "cloudflare-queues"
kind: "queue"
provider: "cloudflare"
docs: "https://developers.cloudflare.com/queues/platform/limits/"
defaults:
  managed: true
  delivery: "at-least-once"
  ordering: "none"
  deadLetterQueue: false
  replay: false
  persistence: true
  retentionDays: 1
  maxAttempts: 3
  role: "work"
properties:
  maxBatchSize:
    type: "integer"
    default: 100
  maxMessageSizeKb:
    type: "integer"
    default: 128
  maxConsumerConcurrency:
    type: "integer"
    default: 250
  consumerType:
    type: "enum"
    values: ["push", "pull"]
    default: "push"
  maxRetentionDays:
    type: "integer"
    default: 14

The same page as markdown, for an agent: /catalogue/components/cloudflare-queues.md