CAMEL-11279: Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/921fa67d Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/921fa67d Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/921fa67d Branch: refs/heads/camel-2.19.x Commit: 921fa67da22406de8687c98112c9fa5075382d51 Parents: a306033 Author: Claus Ibsen <davscl...@apache.org> Authored: Tue May 16 12:42:43 2017 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Tue May 16 12:48:30 2017 +0200 ---------------------------------------------------------------------- .../processor/HystrixCircuitOpenTest.java | 20 +++++++++----------- 1 file changed, 9 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/921fa67d/components/camel-hystrix/src/test/java/org/apache/camel/component/hystrix/processor/HystrixCircuitOpenTest.java ---------------------------------------------------------------------- diff --git a/components/camel-hystrix/src/test/java/org/apache/camel/component/hystrix/processor/HystrixCircuitOpenTest.java b/components/camel-hystrix/src/test/java/org/apache/camel/component/hystrix/processor/HystrixCircuitOpenTest.java index 616f828..981c633 100644 --- a/components/camel-hystrix/src/test/java/org/apache/camel/component/hystrix/processor/HystrixCircuitOpenTest.java +++ b/components/camel-hystrix/src/test/java/org/apache/camel/component/hystrix/processor/HystrixCircuitOpenTest.java @@ -17,14 +17,13 @@ package org.apache.camel.component.hystrix.processor; import java.io.IOException; -import org.apache.camel.CamelExecutionException; +import org.apache.camel.CamelExecutionException; import org.apache.camel.Exchange; import org.apache.camel.Processor; import org.apache.camel.RoutesBuilder; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.test.junit4.CamelTestSupport; - import org.junit.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -35,7 +34,7 @@ import static org.apache.camel.component.hystrix.processor.HystrixConstants.HYST public class HystrixCircuitOpenTest extends CamelTestSupport { public static final Integer REQUEST_VOLUME_THRESHOLD = 4; private static final Logger LOG = LoggerFactory.getLogger(HystrixCircuitOpenTest.class); - + private HystrixExceptionRoute route = new HystrixExceptionRoute(); @Test @@ -88,19 +87,19 @@ public class HystrixCircuitOpenTest extends CamelTestSupport { assertMockEndpointsSatisfied(); } - + @Override protected RoutesBuilder createRouteBuilder() throws Exception { return route; } class HystrixExceptionRoute extends RouteBuilder { - volatile boolean throwException = true; - + volatile boolean throwException = true; + @Override public void configure() throws Exception { from("direct:start") - .hystrix() + .hystrix() .hystrixConfiguration() .executionTimeoutInMilliseconds(100) .circuitBreakerRequestVolumeThreshold(REQUEST_VOLUME_THRESHOLD) @@ -120,10 +119,9 @@ public class HystrixCircuitOpenTest extends CamelTestSupport { } }) .log("Hystrix processing end: ${threadName}") - .end() - .log(HYSTRIX_RESPONSE_SHORT_CIRCUITED + " = ${exchangeProperty." + HYSTRIX_RESPONSE_SHORT_CIRCUITED + "}") - .to("mock:result"); - + .end() + .log(HYSTRIX_RESPONSE_SHORT_CIRCUITED + " = ${exchangeProperty." + HYSTRIX_RESPONSE_SHORT_CIRCUITED + "}") + .to("mock:result"); } } }
