Module resequencer 

Resequencer — continuation-boundary EIP.

The resequencer is a CompiledStep + StepLifecycle. call(input) sends the input into a bounded actor channel; an actor buffers + computes ready outputs + sends them to a post-driver that drives the owned post-continuation; call() returns a control ack. The main pipeline ends at the resequencer.

Architecture: See ADR-0029 (resequencer continuation boundary).

Modules

batch

Batch resequencing policy — buffer per correlation key, window completion, sort by expression, burst-emit in order.

stream

Stream resequencing policy — bounded priority queue keyed by sequence number, gap detection with per-gap timeout, capacity cap, opt-in dedup.

Structs

PassthroughPolicy

Emits each input unchanged — used as a baseline policy for testing the continuation-boundary mechanics.

ResequencerConfig

Configuration for the ResequencerService.

ResequencerService

Continuation-boundary resequencer.

Constants

CAMEL_RESEQUENCER_ACCEPTED

Set on the ack exchange: true when the resequencer accepted the input.

CAMEL_RESEQUENCER_DROPPED

Set on the ack exchange: true when the input was dropped during shutdown.

CAMEL_RESEQUENCER_INOUT_WARN

Set on the ack exchange: true when an InOut exchange reaches the resequencer.

Traits

ResequencePolicy

Buffer / ordering policy for a resequencer.