fetchfetchqueue handlers in the same project, then just do it like this
queueexport default {
fetch: app.fetch,
async queue(...) { ... }
}
V
V
scheduled worker right?
A
M
M
U
UM
M
F
M
contentType option [1] and dead letter queues [2].contentType is set to anything other than "v8" and the queue event ends up in the DLQ, a consumer worker attached to that DLQ cannot handle it.MAAM
MMA
D
HDHHDD
S
V
VMMMF
SD
queuesendBatch into the worker either. Is there no solution for this?
AError: Queue send failed: Service Temporarily Unavailable ??AV
S
I
D
GG
scheduledcontentTypecontentType"v8"// Any contentType other than "v8" cannot be handled in the DLQ
env.MY_QUEUE.send({ foo: "bar" }, { contentType: "json" });
// This is handled fine by the DLQ consumer worker
env.MY_QUEUE.send({ foo: "bar" });
// This is also fine
env.MY_QUEUE.send({ foo: "bar" }, { contentType: "v8" });"Unable to deserialize cloned data due to invalid or unsupported version."export interface Env {
MY_QUEUE: Queue;
}
export default {
async fetch(req: Request, env: Env): Promise<Response> {
// Any contentType other than "v8" cannot be handled in the DLQ
await env.MY_QUEUE.send({ foo: 'bar' }, { contentType: 'json' });
return new Response('Sent message to the queue');
},
async queue(batch: MessageBatch<Error>, env: Env): Promise<void> {
// Due to this error, the event will end up in the dead letter queue
throw new Error('Foobar');
},
};export default {
async queue(batch: MessageBatch<Error>, env: Env): Promise<void> {
console.log(`Events received: ${JSON.stringify(batch.messages)}`);
},
};Unknown Event - Exception Thrown @ 10/10/2023, 3:10:17 PM
✘ [ERROR] Error: Unable to deserialize cloned data due to invalid or unsupported version.sendBatchError: Queue send failed: Service Temporarily Unavailable