Expand description
Batch resequencing policy — buffer per correlation key, window completion, sort by expression, burst-emit in order.
Structs§
- Batch
Policy - Batch resequencing policy.
Constants§
- DEFAULT_
MAX_ BUCKETS - Default upper bound on simultaneously open correlation buckets
(audit 2026-08-31, F6-1). Mirrors the aggregator’s
max_bucketsdefault (camel-apiaggregator.rs:209). New keys beyond the cap are dropped. - DEFAULT_
MAX_ BUCKET_ SIZE - Default upper bound on buffered exchanges inside ONE bucket (F6-1). A hot correlation key can otherwise buffer unboundedly until completion fires. Exchanges beyond the cap are dropped (fail-visible: warn + ack drop, same class as the resequencer’s post-ack drop semantics in ADR-0029).
- DEFAULT_
MAX_ TIMEOUT_ TASKS - Default upper bound on live timeout tasks (F6-1). Mirrors the aggregator’s
max_timeout_tasksdefault (camel-apiaggregator.rs:214). When the cap is reached, new buckets still buffer but get no per-key timer — their completion then relies on size or shutdown flush.