Messaging

Messaging patterns change the cardinality or order of exchanges. They split one message into many, gather many into one, reorder a sequence, or sample one in every N. Several compose into split-process-aggregate flows.

• Aggregator — collect exchanges by correlation key and emit a batch
• Splitter — break a composite message into one exchange per fragment
• Streaming Splitter — split a byte-stream body into fragment exchanges with backpressure
• Zip Splitter — split a ZIP archive into one exchange per entry
• Resequencer — reorder exchanges by sequence number in batches or streams
• Sort — sort an array body by a comparator expression
• Sampling — pass through one out of every N exchanges
• Claim Check — stash a large payload and replace it with a claim ticket
• Cache — cache a computed body by key with TTL and stale-read fallback

For the processor contract that implements these patterns, see camel-processor/CONTEXT.md.