In my project i am converting one message format to another. My route builder
contains following pseudo code -
from("source end point")
.policy(PROPAGATION_REQUIRED)
.processRef("inMessageDBWriter") //Write input message to Database
.processRef("processor1")
.processRef("processor2")
.aggregate(My custom strategy)
.constant(true)
.completionSize(5)
.completionInterval(10000L)
.processRef("outMessageDBWriter") //Write output message to Database
.to("destination end point");
Currently i am facing a problem at "outMessageDBWriter" processor, saying
that Transaction is required. I have seen that after aggregation next steps
run in a different thread. So already opened Transaction is not propagate to
the new thread.
How can i resolve this problem?
--
View this message in context:
http://camel.465427.n5.nabble.com/Open-Transaction-is-not-working-after-aggregation-strategy-applying-tp5103177p5103177.html
Sent from the Camel - Users mailing list archive at Nabble.com.
