Page History

from("direct:start").resequencerresequence(body()).batch().to("mock:result");

from("direct:start").resequencerresequence(body()).batch().size(300).timeout(4000L).to("mock:result")

from("direct:start").resequencerresequence(body()).batch(new BatchResequencerConfig(300, 4000L)).to("mock:result")

resequencerresequence(header("JMSPriority"), header("MyCustomerRating"))

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="direct:start" />
    <resequencer><resequence>
      <simple>body</simple>
      <to uri="mock:result" />
      <!-- 
        batch-config can be ommitted for default (batch) resequencer settings
      -->
      <batch-config batchSize="300" batchTimeout="4000" />
    </resequencer>resequence>
  </route>
</camelContext>

from("direct:start").resequencerresequence(header("seqnum")).stream().capacity(5000).timeout(4000L).to("mock:result")

from("direct:start").resequencerresequence(header("seqnum")).stream(new StreamResequencerConfig(5000, 4000L)).to("mock:result")

ExpressionResultComparator<Exchange> comparator = new MyComparator();
from("direct:start").resequencerresequence(header("seqnum")).stream().comparator(comparator).to("mock:result");

ExpressionResultComparator<Exchange> comparator = new MyComparator();
StreamResequencerConfig config = new StreamResequencerConfig(100, 1000L, comparator);
from("direct:start").resequencerresequence(header("seqnum")).stream(config).to("mock:result");

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="direct:start"/>
    <resequencer><resequence>
      <simple>in.header.seqnum</simple>
      <to uri="mock:result" />
      <stream-config capacity="5000" timeout="4000"/>
    </resequencer>resequence>
  </route>
</camelContext>