withastro · matthewp · Apr 7, 2026 · Apr 5, 2026 · Apr 7, 2026
diff --git a/.changeset/fix-cf-prerender-queue-consumers.md b/.changeset/fix-cf-prerender-queue-consumers.md
@@ -0,0 +1,5 @@
+---
+'@astrojs/cloudflare': patch
+---
+
+Fixes `ERR_MULTIPLE_CONSUMERS` error when using Cloudflare Queues with prerendered pages. The prerender worker config callback now excludes `queues.consumers` from the entry worker config, since the prerender worker only renders static HTML and should not register as a queue consumer. Queue producers (bindings) are preserved.
diff --git a/packages/integrations/cloudflare/src/index.ts b/packages/integrations/cloudflare/src/index.ts
@@ -181,11 +181,15 @@ export default function createIntegration({
 						experimental: {
 							prerenderWorker: {
 								config(_, { entryWorkerConfig }) {
+									const { queues, ...restWorkerConfig } = entryWorkerConfig;
 									return {
-										...entryWorkerConfig,
+										...restWorkerConfig,
 										name: 'prerender',
+										...(queues?.producers?.length && {
+											queues: { producers: queues.producers },
+										}),
 										...(needsImagesBinding &&
-											!entryWorkerConfig.images && {
+											!restWorkerConfig.images && {
 												images: { binding: imagesBindingName },
 											}),
 									};

diff --git a/packages/integrations/cloudflare/test/fixtures/prerender-queue-consumers/astro.config.mjs b/packages/integrations/cloudflare/test/fixtures/prerender-queue-consumers/astro.config.mjs
@@ -0,0 +1,7 @@
+import cloudflare from '@astrojs/cloudflare';
+import { defineConfig } from 'astro/config';
+
+export default defineConfig({
+	adapter: cloudflare(),
+	output: 'server',
+});
diff --git a/packages/integrations/cloudflare/test/fixtures/prerender-queue-consumers/package.json b/packages/integrations/cloudflare/test/fixtures/prerender-queue-consumers/package.json
@@ -0,0 +1,9 @@
+{
+  "name": "@test/astro-cloudflare-prerender-queue-consumers",
+  "version": "0.0.0",
+  "private": true,
+  "dependencies": {
+    "@astrojs/cloudflare": "workspace:*",
+    "astro": "workspace:*"
+  }
+}
diff --git a/packages/integrations/cloudflare/test/fixtures/prerender-queue-consumers/src/pages/api.ts b/packages/integrations/cloudflare/test/fixtures/prerender-queue-consumers/src/pages/api.ts
@@ -0,0 +1,9 @@
+import type { APIRoute } from 'astro';
+
+export const prerender = false;
+
+export const GET: APIRoute = async () => {
+	return new Response(JSON.stringify({ ok: true }), {
+		headers: { 'Content-Type': 'application/json' },
+	});
+};
diff --git a/...ges/integrations/cloudflare/test/fixtures/prerender-queue-consumers/src/pages/index.astro b/...ges/integrations/cloudflare/test/fixtures/prerender-queue-consumers/src/pages/index.astro
@@ -0,0 +1,10 @@
+---
+// This page is prerendered by default (output: 'server' with no opt-out)
+// Actually, in output: 'server' mode, pages are server-rendered by default.
+// We explicitly mark this as prerendered.
+export const prerender = true;
+---
+<html>
+<head><title>Prerendered</title></head>
+<body><h1>Prerendered Page</h1></body>
+</html>
diff --git a/packages/integrations/cloudflare/test/fixtures/prerender-queue-consumers/wrangler.jsonc b/packages/integrations/cloudflare/test/fixtures/prerender-queue-consumers/wrangler.jsonc
@@ -0,0 +1,18 @@
+{
+  "name": "prerender-queue-consumers",
+  "main": "@astrojs/cloudflare/entrypoints/server",
+  "compatibility_date": "2026-01-28",
+  "queues": {
+    "consumers": [
+      {
+        "queue": "my-queue"
+      }
+    ],
+    "producers": [
+      {
+        "binding": "MY_QUEUE",
+        "queue": "my-queue"
+      }
+    ]
+  }
+}
diff --git a/packages/integrations/cloudflare/test/prerender-queue-consumers.test.js b/packages/integrations/cloudflare/test/prerender-queue-consumers.test.js
@@ -0,0 +1,33 @@
+import * as assert from 'node:assert/strict';
+import { after, before, describe, it } from 'node:test';
+import { loadFixture } from './_test-utils.js';
+
+describe('Prerender with queue consumers', () => {
+	let fixture;
+	let previewServer;
+
+	before(async () => {
+		fixture = await loadFixture({
+			root: './fixtures/prerender-queue-consumers/',
+		});
+		await fixture.build();
+		previewServer = await fixture.preview();
+	});
+
+	after(async () => {
+		previewServer.stop();
+	});
+
+	it('builds and previews without ERR_MULTIPLE_CONSUMERS', async () => {
+		// The prerendered page should be accessible
+		const res = await fixture.fetch('/');
+		const html = await res.text();
+		assert.ok(html.includes('Prerendered Page'));
+	});
+
+	it('serves the SSR endpoint', async () => {
+		const res = await fixture.fetch('/api');
+		const json = await res.json();
+		assert.deepEqual(json, { ok: true });
+	});
+});
diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml