How will you use Cloudflare’s Queue/Consumer with Nitro/Nuxt?

[they-cloned-me]

There’s mention of using runtime hooks in order to extend worker handlers, but I’ve not yet found a suitable example usage/tutorial on how to do so.

In my code, I’m able to register queues, and send events.

// wrangler.jsonc
  "queues": {
    "producers": [
      {
        "queue": "le-queue",
        "binding": "QUEUE"
      }
    ],
    "consumers": [
      {
        "queue": "le-queue",
        "max_batch_size": 100,
        "max_batch_timeout": 5,
        "max_retries": 3,
        "dead_letter_queue": "le-dead-letter-queue",
      }
    ]
  },

// env.d.ts
import type { Queue } from "@cloudflare/workers-types/experimental";

declare module "h3" {
  interface H3EventContext {
    context: ExecutionContext;
    cloudflare: {
      request: Request;
      env: {
        QUEUE: Queue
      };
    };
  }
}

Somewhere in my code I do:

const message = {
  name: “Pooya”
};

event.context.cloudflare.env.QUEUE.send(message)

1. Where and how will I listen for this and consume it (would love a link to an example if anyone has done this before)?
2. Is there a future where we will have defineQueueHandler or something similar, just like we have defineWebSocketHandler?

Thanks, and apologies for pinging 🙈
cc @pi0 @atinux @TheAlexLichter 🫶

[they-cloned-me]

Maybe listen for this in a plugin?

// server/plugins/000.queue.ts
import { MessageBatch } from "@cloudflare/workers-types/experimental";

export default defineNitroPlugin((nitro) => {
  nitro.hooks.hook("cloudflare:queue", async (params: {
    batch: MessageBatch;
  }) => {
   // 🤔 🫤
    console.log(params.batch.messages)
  });
});