hello,
Okay even if I use spring transaction, i still don't get it if the
processing is fail safe even if I set Ack to false
For example I have a route as below and even a dead letter channel
configured. In the error handler I am logging the message in a DB in case
if it was not delivered. But what will happen in case the message was not
logged in the DB due to some environment error etc. What happens to the
message , will the Active MQ get the ACK . Because as far I have read in
the documentation of camel , as soon as the Processor has finished execution
the ack is sent back. (Hope I am right) even if there was a error or not
after it . How can my scenario be handled in a effective way.
<route errorHandlerRef="CustomErrorHandler" customId="true" id="ROUTE_DATA"
xmlns="http://camel.apache.org/schema/spring";>
<from uri="direct:ACTIVEMQ"/>
<process ref="CustomMapping" id="process2"/>
<multicast parallelProcessing="true"
executorServiceRef="customThreadPoolProfile" id="multicast2">
<pipeline id="pipeline1">
<marshal id="marshal1">
<custom ref="kyroFormat"/>
</marshal>
<to uri="rabbitmq://localhost/HDFSMASTER" id="to9"/>
</pipeline>
<pipeline id="pipeline2">
<process ref="CustomSantizerProcessor" id="process3"/>
<marshal id="marshal2">
<custom ref="kyroFormat"/>
</marshal>
<to uri="rabbitmq://localhost/EXCHANGEMASTER" id="to10"/>
</pipeline>
</multicast>
</route>
<route customId="false" id="CustomErrorRoute"
xmlns="http://camel.apache.org/schema/spring";>
<from uri="direct:ErrorRoute" />
<transform>
<method ref="CustomErrorProcessor"
method="createErrorEntry" />
</transform>
<to uri="sqlComponent:{{sql.insertNewError}}" />
</route>
regards,
Felix T
--
View this message in context:
http://camel.465427.n5.nabble.com/Consume-messages-rollback-tp5773638p5773865.html
Sent from the Camel - Users mailing list archive at Nabble.com.
