Just to clarify… you mean one do object per notification and then set the alarm?
Just to clarify… you mean one do object per notification and then set the alarm?
ctx.waitUntil() to more cheaply and easily defer those operations asynchronously without holding back the response.
queue handler (your consumer) accept a type parameter - so async queue<T>(batch: MessageBatch, env: Env) - which will mean that each message in MessageBatch has a typed payload based on your type parameter T
Error: Queue send failed: Internal Server Error06:22:09, but seems like essentially all sends failed (these are after client-side retries) during that time - worker connection to the rest of cf was ok (I was able to fallback to saving msgs to DO for later playback)ctx.waitUntil()async queue<T>(batch: MessageBatch, env: Env)MessageBatchmax_retries = 10,
retry_delay = 30Error: Queue send failed: Internal Server Error06:22:09