...
Code Block |
---|
public class MyProducer implements Processor { ProducerTemplate producer; public void setProducer(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 Exchangevoid process(Exchange outExchange) { outExchange.getIn().setBody("This is the body"); // set some headers too? } }); } } |
...