ClusteredRedisQueue.once() method
Registers a one-shot listener on every server's queue and on the internal template.
Signature:
once(...args: any[]): this;
Parameters
|
Parameter |
Type |
Description |
|---|---|---|
|
args |
any[] |
the arguments |
Returns:
this
this queue instance
Remarks
Because registration is replicated per server, this arms one independent one-shot listener per server — so the callback may run once for each server in the cluster rather than once overall, and more as servers join. Use ClusteredRedisQueue.on() plus explicit de-registration if you need at-most-once semantics.
Read this page as plain markdown — no HTML, no navigation. For pasting into an LLM, or for an agent to fetch.