Implement Queues simulator as Durable Object

packages/miniflare/README.md

@@ -408,8 +408,6 @@ parameter in module format Workers.
 
 #### Queues
 
-> :warning: Queues are only supported with Node.js 18 or above.
-
 - `queueProducers?: Record<string, string> | string[]`
 
   Record mapping binding name to queue names to inject as `WorkerQueue` bindings

packages/miniflare/src/index.ts

@@ -232,20 +232,14 @@ function getQueueConsumers(
     }
   }
 
-  // Populate all `deadLetterConsumer`s, note this may create cycles
   for (const [queueName, consumer] of queueConsumers) {
-    if (consumer.deadLetterQueue !== undefined) {
-      // Check the dead letter queue isn't configured to be the queue itself
-      // (NOTE: Queues *does* permit DLQ cycles between multiple queues,
-      //  i.e. if Q2 is DLQ for Q1, but Q1 is DLQ for Q2)
-      if (consumer.deadLetterQueue === queueName) {
-        throw new QueuesError(
-          "ERR_DEAD_LETTER_QUEUE_CYCLE",
-          `Dead letter queue for queue "${queueName}" cannot be itself`
-        );
-      }
-      consumer.deadLetterConsumer = queueConsumers.get(
-        consumer.deadLetterQueue
+    // Check the dead letter queue isn't configured to be the queue itself
+    // (NOTE: Queues *does* permit DLQ cycles between multiple queues,
+    //  i.e. if Q2 is DLQ for Q1, but Q1 is DLQ for Q2)
+    if (consumer.deadLetterQueue === queueName) {
+      throw new QueuesError(
+        "ERR_DEAD_LETTER_QUEUE_CYCLE",
+        `Dead letter queue for queue "${queueName}" cannot be itself`
       );
     }
   }

packages/miniflare/src/plugins/queues/errors.ts

@@ -1,9 +1,6 @@
-import { HttpError, MiniflareError } from "../../shared";
+import { MiniflareError } from "../../shared";
 
 export type QueuesErrorCode =
-  | "ERR_V8_UNSUPPORTED" // V8 version too old
   | "ERR_MULTIPLE_CONSUMERS" // Attempted to set multiple consumers for a single queue;
   | "ERR_DEAD_LETTER_QUEUE_CYCLE"; // Attempted to set dead letter queue to self
 export class QueuesError extends MiniflareError<QueuesErrorCode> {}
-
-export class QueuesHTTPError extends HttpError {}