Hi all, 

I'm very keen to integrate the circuit breaker EIP in an application, but I
noticed a misbehaviour when I use it with async processors, which is a
common case.

The problem is that the exception in the exchange seems to be populated
after the "hasFailed" method invocation.

To reproduce the error in the junit, I slightly changed the testing route
from:

from("direct:start").loadBalance()
                    .circuitBreaker(2, 1000L, MyCustomException.class)
                        .to("mock:result")

to

from("direct:start").loadBalance()
                    .circuitBreaker(2, 1000L, MyCustomException.class)
                        .threads(1).to("mock:result")

I raised an issue and attached a patch with a proposed fix:
https://issues.apache.org/jira/browse/CAMEL-7973

Matteo



--
View this message in context: 
http://camel.465427.n5.nabble.com/CircuitBreaker-possible-issue-with-async-processor-tp5758295.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Reply via email to