I have the following syntax that I am using to restrict number of redeliveries in ase of an exception. For some reason it is ignoring this parameter, however redeliveryDelay seems to be working. Here is the snippet of the configuration that I am using
<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring";> <errorHandler id="eh" redeliveryPolicyRef="myPolicy"/> <!-- and the redelivery policy is a profile where we can configure it --> <redeliveryPolicyProfile id="myPolicy" maximumRedeliveries="3" redeliveryDelay="5000" /> <route errorHandlerRef="eh"> <from uri="file:C:\temp\sample" /> <split streaming="true" parallelProcessing="true"> <tokenize token="\n" group="1" /> <unmarshal> <csv delimiter="|" /> </unmarshal> <to uri="bean:exampleProcessor" /> <to uri="velocity:velocity/to-exampleRecord.vm?contentCache=false?propertiesFile=velocity/velocity.properties" /> <to uri="my-rest-server://{{Username}}:{{Password}}@{{Host}}:{{Port}}?format=xml&" /> </split> </route> </camelContext> I am getting java.lang.IndexOutOfBoundsException and the camel still trying to process the file after the maximumRdeliveries of 3. It is just ignoring this parameter which is specified as part of the policy. Please help me to understand, what I am doing wrong? Here is the exception [Camel (camel) thread #4 - file://C:%5CUsers%5Cviyengar%5Ctemp%5Ckms%5Crec] GenericFileOnCompletion WARN Rollback file strategy: org.apache.camel.component. file.strategy.GenericFileRenameProcessStrategy@1a8a582d for file: GenericFile[C:\temp\sample\sample-1.csv] java.lang.IndexOutOfBoundsException: Index: 24, Size: 24 at java.util.ArrayList.rangeCheck(ArrayList.java:653) at java.util.ArrayList.get(ArrayList.java:429) at com.example.camel.processor.ExampleProcessor.processCsv(ExampleProcessor.java:80) at sun.reflect.GeneratedMethodAccessor138.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:483) at org.apache.camel.component.bean.MethodInfo.invoke(MethodInfo.java:408) at org.apache.camel.component.bean.MethodInfo$1.doProceed(MethodInfo.java:279) at org.apache.camel.component.bean.MethodInfo$1.proceed(MethodInfo.java:252) at org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:177) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:109) at org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:68) at org.apache.camel.component.bean.BeanProducer.process(BeanProducer.java:38) at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:141) at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77) at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190) at org.apache.camel.processor.Pipeline.process(Pipeline.java:121) at org.apache.camel.processor.Pipeline.process(Pipeline.java:83) at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:109) at org.apache.camel.processor.MulticastProcessor.doProcessParallel(MulticastProcessor.java:814) at org.apache.camel.processor.MulticastProcessor.access$200(MulticastProcessor.java:84) at org.apache.camel.processor.MulticastProcessor$1.call(MulticastProcessor.java:314) at org.apache.camel.processor.MulticastProcessor$1.call(MulticastProcessor.java:299) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
