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/dd0f74c0 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/dd0f74c0 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/dd0f74c0 Branch: refs/heads/master Commit: dd0f74c002d57b5b2f4da446b67d4194301c6335 Parents: 323ab6b 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:11:45 2015 +0200 ---------------------------------------------------------------------- .../processor/loadbalancer/CircuitBreakerLoadBalancer.java | 5 ----- 1 file changed, 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/dd0f74c0/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; }
