Struct AggregatorConfig 

pub struct AggregatorConfig {
    pub header_name: String,
    pub completion: CompletionMode,
    pub correlation: CorrelationStrategy,
    pub strategy: AggregationStrategy,
    pub max_buckets: Option<usize>,
    pub bucket_ttl: Option<Duration>,
    pub force_completion_on_stop: bool,
    pub discard_on_timeout: bool,
    pub max_timeout_tasks: usize,
}

Configuration for the Aggregator EIP.

Fields

header_name: String

Name of the header used as correlation key.

completion: CompletionMode

When to emit the aggregated exchange.

correlation: CorrelationStrategy

Strategy for determining correlation keys.

strategy: AggregationStrategy

How to combine the bucket into one exchange.

max_buckets: Option<usize>

Maximum number of correlation key buckets (memory protection). When limit is reached, new correlation keys are rejected.

bucket_ttl: Option<Duration>

Time-to-live for inactive buckets (memory protection). Buckets not updated for this duration are evicted.

force_completion_on_stop: bool

Force-complete all pending buckets when the route is stopped.

discard_on_timeout: bool

Discard bucket contents on timeout instead of emitting.

max_timeout_tasks: usize

Maximum number of concurrently-live per-bucket timeout tasks (DoS cap, R3-M3). When the cap is reached, new buckets skip the dedicated timeout spawn and rely on bucket_ttl eviction (graceful degradation under a key flood). Default 1024.

Implementations

impl AggregatorConfig

pub fn correlate_by(header: impl Into<String>) -> AggregatorConfigBuilder

Start building config with correlation key extracted from the named header.

pub fn validate(&self) -> Result<(), CamelError>

Validate that at least one memory-release bound is configured (R3-M2).

At least one of max_buckets, a Timeout completion condition, or bucket_ttl MUST be set, otherwise a flood of unique correlation keys grows the bucket map without limit (remote-OOM vector).

Additionally, when a Timeout completion condition is present, bucket_ttl MUST also be set. The R3-M3 timeout-task cap may skip spawning a dedicated timeout task under flood; without bucket_ttl there is no fallback eviction path and the bucket leaks until shutdown. Requiring bucket_ttl whenever Timeout is present makes the cap-skip degradation safe by construction.

Trait Implementations

impl Clone for AggregatorConfig

fn clone(&self) -> AggregatorConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.