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.
M
AAM
MMA
D
HDHHDD
S
V
VMMMF
SD
queuesendBatch
AError: Queue send failed: Service Temporarily Unavailable
S
I
D
GGGI
M
OO
KO
async queue(batch: MessageBatch<TransactionModel>, env: Bindings): Promise<void> {
try {
let messages = JSON.stringify(batch.messages);
console.log(`consumed from our queue: ${JSON.stringify(messages)}`);
} catch (error) {
console.log('Error=>',error);
}
},contentTypecontentType"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.