U
T
U
K
S
MS
MSMS
C
H
send
BDevelopers building on Queues can now create up to 10,000 queues per account, enabling easier per-user, per-job and sharding use-cases.
MBenv["some-queue-" + userId].send(...)?M
A
BB
QQBB
message.queue gives the name of the queue. I would like to avoid having to pass the queue names as additional variables (next to the bindings)MMessageBatch type that contains the messages delivered to the consumer has the queue name: https://developers.cloudflare.com/queues/reference/javascript-apis/#messagebatchB
if (msg.queue === env.SOME_QUEUE_BINDING.name) ...Bstaging.some-queue.v1 ) and so on, but was wondering if we could derive the queue name from the binding directly
AMessages delivered to a DLQ without an active consumer will persist for four (4) days before being deleted from the queue.
MMA
AUA
DD
J
wrangler.toml
A
F
It looks like a long wait until something better than your solution. (Myself is sticking with GCT until its ”fixed”. Works great in dev also)DV
MV
queue.getMessages() to return an array[] will helps us to find if a message already exists with retryqueue.getCount() to return the number of messages currently in queue to wait or move some tasks to other services.message.retryCount() to get if a message is already retried > 3 times to take actionM
Zenv["some-queue-" + userId].send(...)message.queueMessageBatchif (msg.queue === env.SOME_QUEUE_BINDING.name) ...staging.some-queue.v1 async queue(batch: MessageBatch<Message>, env: Env): Promise<void> {
batch.ackAll();
for (const message of batch.messages) {
const task = message.body as unknown as Task;
// d1.insert(`Running task ${task.id}`);
// Heavy processing here may take upto 1 minute per batch
}
}queue.getMessages()queue.getCount()message.retryCount()