Skip to main content

Crate nest_rs_queue_macros

Crate nest_rs_queue_macros 

Source
Expand description

The #[processor] decorator, re-exported by nest-rs-queue (the backend-agnostic abstractions crate) so the call site keeps writing use nest_rs_queue::processor; regardless of which backend integration (nest-rs-redis, …) is wired in.

Attribute Macros§

processor
Orchestrator on an #[injectable] provider’s impl block. Each method tagged with #[process(queue = "...", concurrency, retries)] becomes a queue consumer the QueueWorker spawns at boot.
queue
Stamp a unit struct with a compile-time queue identity — its wire name and the Job payload it carries — by implementing QueueName. Lives beside the payload at the feature port; both the producer (push_to::<Q>) and the consumer (#[process(queue = Q)]) name the type, so a typo’d name or a mismatched payload is a compile error, not a job that silently never drains.