from("direct:start").process(new Processor() {
public void process(Exchange exchange) throws Exception {
// force some error so Camel will do redelivery
if (++counter <= 3) {
throw new MyTechnicalException("Forced by unit test");
}
}
}).to("mock:result");
}