Based on this example of a camel route
<aggregate id="ag.2" strategyRef="second.aggregator.strategy"
aggregationRepositoryRef="aggregator.container.2" completionSize="2"
completionTimeout="360000">
<correlationExpression>
<header>aggregationKey</header>
</correlationExpression>
<multicast stopOnException="false" >
<to uri="direct:1.IN.SPRING.REMOTING" />
<to uri="direct:2.IN.SPRING.REMOTING" />
<to uri="direct:3.IN.SPRING.REMOTING" />
</multicast>
</aggregate>
<route autoStartup="true" >
<from uri="direct:1.IN.SPRING.REMOTING" />
<transform>
<method bean="converter" method="toTestRequest"/>
</transform>
<to uri="bean:spring.remote?method=springRemotingTest(${body})" />
<onCompletion onCompleteOnly="true" >
<process ref="post.processor" />
<to uri="jms:COMPLETED" />
</onCompletion>
</route>
<route autoStartup="true" >
<from uri="direct:2.IN.SPRING.REMOTING" />
<transform>
<method bean="converter" method="toTestRequest"/>
</transform>
<to uri="bean:spring.remote?method=springRemotingTest2(${body})" />
<onCompletion onCompleteOnly="true" >
<process ref="post.processor" />
<to uri="jms:COMPLETED" />
</onCompletion>
</route>
<route autoStartup="true" >
<from uri="direct:3.IN.SPRING.REMOTING" />
<transform>
<method bean="converter" method="toTestRequest"/>
</transform>
<to uri="bean:spring.remote?method=springRemotingTest3(${body})" />
<onCompletion onCompleteOnly="true" >
<process ref="post.processor" />
<to uri="jms:COMPLETED" />
</onCompletion>
</route>
I want to retry independent from each other if one fails. The behavior now
is if one fails the three routes will be retried. I tried to do a custom
error hander but the behavior was the same.
¿Any idea?
Best regards
Erwin
