Page History

public class MyProcessorMyProducer implements Processor {
  ProducerTemplate<Exchange>ProducerTemplate producer;

  public void setProducer(ProducerTemplate<Exchange>ProducerTemplate producer) {
    this.producer = producer;
  }

  public void process(Exchange inExchange) {
    // some loop for each message 
    for (String template in templates) {
       // lets send a new exchange to the producers default destination
       // being called back so we can customize the message
       producer.send(new Processor() {
          public Exchange process(Exchange outExchange) {
              outExchange.getIn().setBody("This is the body"); 
              // set some headers too?
          }
       });
    }
}