1# Queues Configuration
2 
3## Create Queue
4 
5```bash
6wrangler queues create my-queue
7wrangler queues create my-queue --retention-period-hours=336  # 14 days
8wrangler queues create my-queue --delivery-delay-secs=300
9```
10 
11## Producer Binding
12 
13**wrangler.jsonc:**
14```jsonc
15{
16  "queues": {
17    "producers": [
18      {
19        "queue": "my-queue-name",
20        "binding": "MY_QUEUE",
21        "delivery_delay": 60  // Optional: default delay in seconds
22      }
23    ]
24  }
25}
26```
27 
28## Consumer Configuration (Push-based)
29 
30**wrangler.jsonc:**
31```jsonc
32{
33  "queues": {
34    "consumers": [
35      {
36        "queue": "my-queue-name",
37        "max_batch_size": 10,           // 1-100, default 10
38        "max_batch_timeout": 5,         // 0-60s, default 5
39        "max_retries": 3,               // default 3, max 100
40        "dead_letter_queue": "my-dlq",  // optional
41        "retry_delay": 300              // optional: delay retries in seconds
42      }
43    ]
44  }
45}
46```
47 
48## Consumer Configuration (Pull-based)
49 
50**wrangler.jsonc:**
51```jsonc
52{
53  "queues": {
54    "consumers": [
55      {
56        "queue": "my-queue-name",
57        "type": "http_pull",
58        "visibility_timeout_ms": 5000,  // default 30000, max 12h
59        "max_retries": 5,
60        "dead_letter_queue": "my-dlq"
61      }
62    ]
63  }
64}
65```
66 
67## TypeScript Types
68 
69```typescript
70interface Env {
71  MY_QUEUE: Queue<MessageBody>;
72  ANALYTICS_QUEUE: Queue<AnalyticsEvent>;
73}
74 
75interface MessageBody {
76  id: string;
77  action: 'create' | 'update' | 'delete';
78  data: Record<string, any>;
79}
80 
81export default {
82  async queue(batch: MessageBatch<MessageBody>, env: Env): Promise<void> {
83    for (const msg of batch.messages) {
84      console.log(msg.body.action);
85      msg.ack();
86    }
87  }
88} satisfies ExportedHandler<Env>;
89```
90 
91## Content Type Selection
92 
93Choose content type based on consumer type and data requirements:
94 
95| Content Type | Use When | Readable By | Supports | Size |
96|--------------|----------|-------------|----------|------|
97| `json` | Pull consumers, dashboard visibility, simple objects | All (push/pull/dashboard) | JSON-serializable types only | Medium |
98| `v8` | Push consumers only, complex JS objects | Push consumers only | Date, Map, Set, BigInt, typed arrays | Small |
99| `text` | String-only payloads | All | Strings only | Smallest |
100| `bytes` | Binary data (images, files) | All | ArrayBuffer, Uint8Array | Variable |
101 
102**Decision tree:**
1031. Need to view in dashboard or use pull consumer? → Use `json`
1042. Need Date, Map, Set, or other V8 types? → Use `v8` (push consumers only)
1053. Just strings? → Use `text`
1064. Binary data? → Use `bytes`
107 
108```typescript
109// JSON: Good for simple objects, pull consumers, dashboard visibility
110await env.QUEUE.send({ id: 123, name: 'test' }, { contentType: 'json' });
111 
112// V8: Good for Date, Map, Set (push consumers only)
113await env.QUEUE.send({ 
114  created: new Date(), 
115  tags: new Set(['a', 'b']) 
116}, { contentType: 'v8' });
117 
118// Text: Simple strings
119await env.QUEUE.send('process-user-123', { contentType: 'text' });
120 
121// Bytes: Binary data
122await env.QUEUE.send(imageBuffer, { contentType: 'bytes' });
123```
124 
125**Default behavior:** If not specified, Cloudflare auto-selects `json` for JSON-serializable objects and `v8` for complex types.
126 
127**IMPORTANT:** `v8` messages cannot be read by pull consumers or viewed in the dashboard. Use `json` if you need visibility or pull-based consumption.
128 
129## CLI Commands
130 
131```bash
132# Consumer management
133wrangler queues consumer add my-queue my-worker --batch-size=50 --max-retries=5
134wrangler queues consumer http add my-queue
135wrangler queues consumer worker remove my-queue my-worker
136wrangler queues consumer http remove my-queue
137 
138# Queue operations
139wrangler queues list
140wrangler queues pause my-queue
141wrangler queues resume my-queue
142wrangler queues purge my-queue
143wrangler queues delete my-queue
144```
145