Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/1569aa42 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1569aa42 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1569aa42 Branch: refs/heads/master Commit: 1569aa42a8be0d3280c527b13c38b138ad931f35 Parents: 7e5be55 Author: Claus Ibsen <davscl...@apache.org> Authored: Fri Apr 29 07:18:35 2016 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Apr 29 08:46:49 2016 +0200 ---------------------------------------------------------------------- .../builder/FluentProducerTemplateTest.java | 26 ++++++++++---------- 1 file changed, 13 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/1569aa42/camel-core/src/test/java/org/apache/camel/builder/FluentProducerTemplateTest.java ---------------------------------------------------------------------- diff --git a/camel-core/src/test/java/org/apache/camel/builder/FluentProducerTemplateTest.java b/camel-core/src/test/java/org/apache/camel/builder/FluentProducerTemplateTest.java index 27504f3..c25a1a1 100644 --- a/camel-core/src/test/java/org/apache/camel/builder/FluentProducerTemplateTest.java +++ b/camel-core/src/test/java/org/apache/camel/builder/FluentProducerTemplateTest.java @@ -125,11 +125,11 @@ public class FluentProducerTemplateTest extends ContextTestSupport { Exchange out = FluentProducerTemplate.on(context) .withExchange(() -> { - Exchange exchange = context.getEndpoint("direct:exception").createExchange(); - exchange.getIn().setBody("Hello World"); + Exchange exchange = context.getEndpoint("direct:exception").createExchange(); + exchange.getIn().setBody("Hello World"); - return exchange; - }) + return exchange; + }) .to("direct:exception") .send(); @@ -179,11 +179,11 @@ public class FluentProducerTemplateTest extends ContextTestSupport { Exchange out = FluentProducerTemplate.on(context) .withExchange(() -> { - Exchange exchange = context.getEndpoint("direct:exception").createExchange(ExchangePattern.InOut); - exchange.getIn().setBody("Hello World"); + Exchange exchange = context.getEndpoint("direct:exception").createExchange(ExchangePattern.InOut); + exchange.getIn().setBody("Hello World"); - return exchange; - }) + return exchange; + }) .to("direct:exception") .send(); @@ -273,15 +273,15 @@ public class FluentProducerTemplateTest extends ContextTestSupport { from("direct:fault").process( exchange -> { - exchange.getOut().setFault(true); - exchange.getOut().setBody("Faulty World"); - }) + exchange.getOut().setFault(true); + exchange.getOut().setBody("Faulty World"); + }) .to("mock:result"); from("direct:exception").process( exchange -> { - throw new IllegalArgumentException("Forced exception by unit test"); - }) + throw new IllegalArgumentException("Forced exception by unit test"); + }) .to("mock:result"); from("direct:inout").transform(constant(123));
