Struct SedaConfig 

pub struct SedaConfig {
    pub name: String,
    pub size: usize,
    pub concurrent_consumers: usize,
    pub multiple_consumers: bool,
    pub block_when_full: bool,
    pub discard_if_no_consumers: bool,
    pub timeout_ms: u64,
    pub wait_for_task_to_complete: WaitForTaskToComplete,
    pub exchange_pattern: ExchangePattern,
}

Configuration parsed from a SEDA URI.

URI format: seda:name[?options]

Options are split into two groups:

• shared: validated for consistency when multiple endpoints reference the same endpoint name (size, multiple_consumers, exchange_pattern, concurrent_consumers).
• producer only: stored per-endpoint, used only by the producer (block_when_full, discard_if_no_consumers, timeout_ms, wait_for_task_to_complete).

Fields

name: String

size: usize

concurrent_consumers: usize

multiple_consumers: bool

block_when_full: bool

discard_if_no_consumers: bool

timeout_ms: u64

wait_for_task_to_complete: WaitForTaskToComplete

exchange_pattern: ExchangePattern

Implementations

impl SedaConfig

pub fn from_uri(uri: &str) -> Result<Self, CamelError>

Trait Implementations

impl Clone for SedaConfig

fn clone(&self) -> SedaConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SedaConfig

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

Formats the value using the given formatter.