N
FN
O
L
A
M
L
К
HH
J
Queue send failed: Queue is overloaded. Please back off. for the first time. Does that only happen when the max per-queue message throughput is exceeded? (ie currently 400/s)
L
LM
Too Many Requests when you hit the rate limit. Did you exceed your backlog in a single queue?J
Queue send failed: Queue is overloaded. Please back off. was received from workers all over the world at around the same time (calling .send on a queue). .send and the queue storage?.send would only fail when exceeding the msg/s limits (globally) or some truly edge case node failure where it couldn't even save to any sort of recoverable internal storage.
MMM
M
SS
J
CCC
C
ZMMMM
add() is not a method on a Queue. Where are you seeing this? add() is not mentioned in the tutorial. send() is what you want to call. M
We'll have more updates to share publicly next week.M
UU
WWM
V
Queue send failed: Queue is overloaded. Please back off.Queue send failed: Queue is overloaded. Please back off.Too Many Requests.send.send.send➜ curl "https://api.cloudflare.com/client/v4/accounts/${CF_ACCOUNT_ID}/queues/${QUEUE_ID}/messages/pull" -X POST --data '{}' \
-H "Authorization: Bearer ${QUEUES_TOKEN}" \
-H "Content-Type:application/json"add()add()send()for (const msg of batch.messages) {// Delay a singular message by 600 seconds (10 minutes)
await env.YOUR_QUEUE.send(message, { delaySeconds: 600 })export default {
async queue(batch: MessageBatch, env: Env, ctx: ExecutionContext) {
for (const msg of batch.messages) {
// Mark for retry and delay a singular message
// by 3600 seconds (1 hour)
msg.retry({delaySeconds: 3600})
}
},
};