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’simplblock. Each method tagged with#[process(queue = "...", concurrency, retries)]becomes a queue consumer theQueueWorkerspawns at boot. - queue
- Stamp a unit struct with a compile-time queue identity — its wire name and
the
Jobpayload it carries — by implementingQueueName. 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.