Struct QueueConfig 

pub struct QueueConfig {
    pub name: String,
    pub mode: QueueMode,
    pub durable: bool,
    pub auto_delete: bool,
    pub max_message_size: Option<usize>,
    pub message_ttl: Option<Duration>,
}

Queue configuration

Examples

use celers_kombu::{QueueConfig, QueueMode};
use std::time::Duration;

let config = QueueConfig::new("my_queue".to_string())
    .with_mode(QueueMode::Priority)
    .with_ttl(Duration::from_secs(3600))
    .with_durable(true)
    .with_max_message_size(1024 * 1024);

assert_eq!(config.name, "my_queue");
assert_eq!(config.mode, QueueMode::Priority);
assert_eq!(config.message_ttl, Some(Duration::from_secs(3600)));
assert!(config.durable);
assert_eq!(config.max_message_size, Some(1024 * 1024));

Fields

name: String

Queue name

mode: QueueMode

Queue mode

durable: bool

Durable (survive broker restart)

auto_delete: bool

Auto-delete (delete when no consumers)

max_message_size: Option<usize>

Maximum message size

message_ttl: Option<Duration>

Message TTL (time-to-live)

Implementations

impl QueueConfig

pub fn new(name: String) -> Self

pub fn with_mode(self, mode: QueueMode) -> Self

pub fn with_ttl(self, ttl: Duration) -> Self

pub fn with_durable(self, durable: bool) -> Self

Set durability

pub fn with_auto_delete(self, auto_delete: bool) -> Self

Set auto-delete

pub fn with_max_message_size(self, size: usize) -> Self

Set max message size

Trait Implementations

impl Clone for QueueConfig

fn clone(&self) -> QueueConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for QueueConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.