问不带对象模型的BytesMessage

EN

<route>
<from uri="direct:start"/>
<pipeline>
    <to uri="bean:checkLuggage"/>
    <to uri="mock:testCheckpoint"/>
    <to uri="bean:dataEnricher"/>
    <to uri="mock:result"/>
</pipeline>
</route>

public static final class CheckLuggageBean {        
  public void checkLuggage(Exchange exchange, @Body String body, @XPath("/order/@custId") String custId) {   
    // store the message body into the data store, using the custId as the claim check
    dataStore.put(custId, body);
    // add the claim check as a header
    exchange.getIn().setHeader("claimCheck", custId);
    // remove the body from the message
    exchange.getIn().setBody(null);
}

public static final class DataEnricherBean {
  public void addDataBackIn(Exchange exchange, @Header("claimCheck") String claimCheck) { 
    // query the data store using the claim check as the key and add the data
    // back into the message body
    exchange.getIn().setBody(dataStore.get(claimCheck));
    // remove the message data from the data store
    dataStore.remove(claimCheck);
    // remove the claim check header
    exchange.getIn().removeHeader("claimCheck");
  }
}