AAA
BAA
I
SSSS
O
M
MOO
CO
TC
A
bodybody
BO
PM
M
IM
0S
Z
P
A
SST
P
bunx wrangler dev but when I go to the url it runs on it just hangs for a while with no error output. After a reasonable amount of time it will start lagging out my computer and starts spamming to console
M
F
K[[env.???.queues.consumers]]/[[env.???.queues.producers]]FFPinterface TypedMessageBatch<Name extends string, Body> {
readonly messages: readonly Message<Body>[];
readonly queue: Name;
retryAll(options?: QueueRetryOptions): void;
ackAll(): void;
}
type MessageBatch =
| TypedMessageBatch<"queue-1", { foo: number }>
| TypedMessageBatch<"queue-2", { bar: number }>;
export default class extends WorkerEntrypoint<Env> {
async queue(_batch: MessageBatch) {
switch (batch.queue) {
case "queue-1": {
// message.body is typed
break;
}
}
}
}const Body = z.union(
z.object({ type: "A", data: {...} }),
z.object({ type: "B", data: {...} })
);
try {
msg = Body.parse(await req.json()); // msg is now guaranteed to match the `Body` schema
} catch (err) {
return new Response("Invalid body", { status: 400 });
}
await env.QUEUE.send(msg);export default {
async fetch(request: Request<unknown, IncomingRequestCfProperties<unknown>>, env: Env, ctx: ExecutionContext): Promise<Response> {
await env.aramDataCollectionQueue.send({
riot_puuid: "secret",
region: RegionGroups.SEA
})
return new Response("Success");
},
queue(batch: MessageBatch<CollectAramDataJob>, env: Env, ctx: ExecutionContext): void | Promise<void> {
console.log(batch);
}
} satisfies ExportedHandler<Env, CollectAramDataJob>bunx wrangler dev[wrangler:inf] GET / 500 Internal Server Error (78202ms)[[env.???.queues.consumers]][[env.???.queues.producers]]export async function queue(batch, env) {
console.log({ messages: JSON.stringify(batch.messages) }) // This logs an array of 3 objects
for (const msg of batch.messages) {
console.log({ message: JSON.stringify(msg) }) // This only logs twice
try {
// ...do things
msg.ack()
} catch (e) {
console.error(`adjustUser error: ${e}`) // This never logs
msg.retry()
}
}
}[[queues.producers]]
queue = "adjust-user"
binding = "ADJUST_USER_QUEUE"
[[queues.consumers]]
queue = "adjust-user"
max_batch_size = 10
max_batch_timeout = 5
retry_delay = 600
dead_letter_queue = "failed-adjust-user"