Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3a172f74 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3a172f74 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3a172f74 Branch: refs/heads/master Commit: 3a172f74a9fe1931ec488be71b66a3999cc3ceb0 Parents: b8e2604 Author: Claus Ibsen <[email protected]> Authored: Fri Mar 4 14:02:59 2016 +0100 Committer: Claus Ibsen <[email protected]> Committed: Fri Mar 4 14:02:59 2016 +0100 ---------------------------------------------------------------------- .../netty4/http/NettyHttpRedeliveryTest.java | 26 ++++++++++---------- 1 file changed, 13 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/3a172f74/components/camel-netty4-http/src/test/java/org/apache/camel/component/netty4/http/NettyHttpRedeliveryTest.java ---------------------------------------------------------------------- diff --git a/components/camel-netty4-http/src/test/java/org/apache/camel/component/netty4/http/NettyHttpRedeliveryTest.java b/components/camel-netty4-http/src/test/java/org/apache/camel/component/netty4/http/NettyHttpRedeliveryTest.java index 0f65024..cab7d8f 100644 --- a/components/camel-netty4-http/src/test/java/org/apache/camel/component/netty4/http/NettyHttpRedeliveryTest.java +++ b/components/camel-netty4-http/src/test/java/org/apache/camel/component/netty4/http/NettyHttpRedeliveryTest.java @@ -19,7 +19,6 @@ package org.apache.camel.component.netty4.http; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; -import org.apache.camel.CamelExecutionException; import org.apache.camel.Exchange; import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; @@ -50,22 +49,23 @@ public class NettyHttpRedeliveryTest extends BaseNettyTest { @Override public void configure() throws Exception { onException(Exception.class) - .maximumRedeliveries(50).redeliveryDelay(100).onExceptionOccurred(new Processor() { - @Override - public void process(Exchange exchange) throws Exception { - // signal to start the route (after 5 attempts) - latch.countDown(); - // and there is only 1 inflight - assertEquals(1, context.getInflightRepository().size()); - } - }); + .maximumRedeliveries(50).redeliveryDelay(100).onExceptionOccurred( + new Processor() { + @Override + public void process(Exchange exchange) throws Exception { + // signal to start the route (after 5 attempts) + latch.countDown(); + // and there is only 1 inflight + assertEquals(1, context.getInflightRepository().size()); + } + }); from("timer:foo").routeId("foo") - .to("netty4-http:http://0.0.0.0:{{port}}/bar?keepAlive=false&disconnect=true";) - .to("mock:result"); + .to("netty4-http:http://0.0.0.0:{{port}}/bar?keepAlive=false&disconnect=true";) + .to("mock:result"); from("netty4-http:http://0.0.0.0:{{port}}/bar";).routeId("bar").autoStartup(false) - .setBody().constant("Bye World"); + .setBody().constant("Bye World"); } }; }
