Skip to main content

queue

Attribute Macro queue 

Source
#[queue]
Expand description

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.

#[queue(name = "audio", job = TranscodeCommand)]
pub struct AudioQueue;

§Expands to

pub struct AudioQueue;
impl ::nest_rs_queue::QueueName for AudioQueue {
    const NAME: &'static str = "audio";
    type Job = TranscodeCommand;
}