Enum ResequenceMode 

pub enum ResequenceMode {
    Batch {
        correlation: String,
        sort: String,
        completion: BatchCompletion,
    },
    Stream {
        sequence: String,
        capacity: usize,
        gap_timeout: u64,
        on_gap: GapPolicy,
        on_capacity_exceeded: CapacityPolicy,
        dedup: bool,
    },
}

Configurable resequencing policy mode.

Variants

Batch

Window-based batch resequencing.

Fields

correlation: String

Simple-language expression for the correlation key (e.g. "${header.region}").

sort: String

Simple-language expression for the sort key (e.g. "${header.sequence}").

completion: BatchCompletion

Window completion trigger.

Stream

Stream resequencing — bounded priority queue with gap detection.

Fields

sequence: String

Simple-language expression for the sequence number (e.g. "${header.seqNum}"). Must evaluate to a u64.

capacity: usize

Maximum queue size (default 1000).

gap_timeout: u64

Gap timeout in milliseconds (default 5000).

on_gap: GapPolicy

What to do when a gap timer fires.

on_capacity_exceeded: CapacityPolicy

What to do when the queue reaches capacity.

dedup: bool

When true, duplicate/late sequence numbers are ignored. Default false (Camel 4.x behavior: duplicates are inserted).

Trait Implementations

impl Clone for ResequenceMode

fn clone(&self) -> ResequenceMode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ResequenceMode

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

Formats the value using the given formatter.

impl Eq for ResequenceMode

impl PartialEq for ResequenceMode

fn eq(&self, other: &ResequenceMode) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ResequenceMode