CAMEL-8584 Ensure circuit stays open during halfOpenAfter period
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/54c63fc3 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/54c63fc3 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/54c63fc3 Branch: refs/heads/camel-2.15.x Commit: 54c63fc3beb9f63149f2b668f4bdb4b280b519cf Parents: 89928ff Author: jack.perrett <jack.perr...@gamesys.co.uk> Authored: Wed Apr 1 14:48:39 2015 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Thu Apr 2 10:13:38 2015 +0200 ---------------------------------------------------------------------- .../processor/loadbalancer/CircuitBreakerLoadBalancer.java | 5 ----- 1 file changed, 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/54c63fc3/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/CircuitBreakerLoadBalancer.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/CircuitBreakerLoadBalancer.java b/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/CircuitBreakerLoadBalancer.java index f760311..645b477 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/CircuitBreakerLoadBalancer.java +++ b/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/CircuitBreakerLoadBalancer.java @@ -200,11 +200,6 @@ public class CircuitBreakerLoadBalancer extends LoadBalancerSupport implements T private boolean rejectExchange(final Exchange exchange, final AsyncCallback callback) { exchange.setException(new RejectedExecutionException("CircuitBreaker Open: failures: " + failures + ", lastFailure: " + lastFailure)); - /* - * If the circuit opens, we have to prevent the execution of any - * processor. The failures count can be set to 0. - */ - failures.set(0); callback.done(true); return true; }
