This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 77695ca7d6d78773c82833c866b71f373f7e4566 Author: Claus Ibsen <[email protected]> AuthorDate: Mon Jun 12 10:28:59 2023 +0200 Polished --- .../apache/camel/throttling/ThrottlingExceptionRoutePolicy.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/core/camel-support/src/main/java/org/apache/camel/throttling/ThrottlingExceptionRoutePolicy.java b/core/camel-support/src/main/java/org/apache/camel/throttling/ThrottlingExceptionRoutePolicy.java index 94a59b00fb6..e35d833d139 100644 --- a/core/camel-support/src/main/java/org/apache/camel/throttling/ThrottlingExceptionRoutePolicy.java +++ b/core/camel-support/src/main/java/org/apache/camel/throttling/ThrottlingExceptionRoutePolicy.java @@ -127,7 +127,7 @@ public class ThrottlingExceptionRoutePolicy extends RoutePolicySupport implement public void onExchangeDone(Route route, Exchange exchange) { if (keepOpen.get()) { if (state.get() != STATE_OPEN) { - LOG.debug("opening circuit b/c keepOpen is on"); + LOG.debug("Opening circuit (keepOpen is true)"); openCircuit(route); } } else { @@ -143,7 +143,7 @@ public class ThrottlingExceptionRoutePolicy extends RoutePolicySupport implement } /** - * uses similar approach as circuit breaker if the exchange has an exception that we are watching then we count that + * Uses similar approach as circuit breaker if the exchange has an exception that we are watching then we count that * as a failure otherwise we ignore it */ private boolean hasFailed(Exchange exchange) { @@ -214,10 +214,10 @@ public class ThrottlingExceptionRoutePolicy extends RoutePolicySupport implement halfOpenCircuit(route); } } else { - LOG.debug("keeping circuit open (time not elapsed)..."); + LOG.debug("Keeping circuit open (time not elapsed)..."); } } else { - LOG.debug("keeping circuit open (keepOpen is true)..."); + LOG.debug("Keeping circuit open (keepOpen is true)..."); this.addHalfOpenTimer(route); } } @@ -339,7 +339,6 @@ public class ThrottlingExceptionRoutePolicy extends RoutePolicySupport implement } public void setKeepOpen(boolean keepOpen) { - LOG.debug("keep open: {}", keepOpen); this.keepOpen.set(keepOpen); }
