Skip to main content

deferred_queue_name

Function deferred_queue_name 

Source
pub fn deferred_queue_name(queue: &str, suffix: &str, ttl_ms: u32) -> String
Expand description

Name of the hold queue holding ttl_ms-long waits of queue.

The TTL is part of the name on purpose: one queue per distinct delay is what makes a hold queue drain strictly in order (see the module docs). Retries and deferrals with the same rounded delay share the queue.

use queuey_rabbitmq::topology::{deferred_queue_name, DEFAULT_DEFERRED_SUFFIX};
assert_eq!(
    deferred_queue_name("myapp.emails", DEFAULT_DEFERRED_SUFFIX, 30_000),
    "myapp.emails.deferred.30000"
);