Updated Branches: refs/heads/camel-2.12.x 542de1cb9 -> 25ce64371
Fixed test Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/25ce6437 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/25ce6437 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/25ce6437 Branch: refs/heads/camel-2.12.x Commit: 25ce64371e3e9291c72dae17d989fd0c66ce800d Parents: 542de1c Author: Claus Ibsen <davscl...@apache.org> Authored: Mon Nov 11 09:35:58 2013 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon Nov 11 09:40:41 2013 +0100 ---------------------------------------------------------------------- .../component/aws/sqs/SqsFilterMessagesWithNoDeleteTest.java | 4 ++-- .../camel/component/netty/http/ManagedNettyEndpointTest.java | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/25ce6437/components/camel-aws/src/test/java/org/apache/camel/component/aws/sqs/SqsFilterMessagesWithNoDeleteTest.java ---------------------------------------------------------------------- diff --git a/components/camel-aws/src/test/java/org/apache/camel/component/aws/sqs/SqsFilterMessagesWithNoDeleteTest.java b/components/camel-aws/src/test/java/org/apache/camel/component/aws/sqs/SqsFilterMessagesWithNoDeleteTest.java index 9f43f8b..adbe66e 100644 --- a/components/camel-aws/src/test/java/org/apache/camel/component/aws/sqs/SqsFilterMessagesWithNoDeleteTest.java +++ b/components/camel-aws/src/test/java/org/apache/camel/component/aws/sqs/SqsFilterMessagesWithNoDeleteTest.java @@ -72,7 +72,7 @@ public class SqsFilterMessagesWithNoDeleteTest extends TestSupport { ctx.start(); // we shouldn't get - assertIsSatisfied(1000, TimeUnit.MILLISECONDS); + assertIsSatisfied(2000, TimeUnit.MILLISECONDS); // however, the message should not be deleted, that is, it should be left on the queue String response = ctx.createConsumerTemplate().receiveBody(sqsURI, 5000, String.class); @@ -116,7 +116,7 @@ public class SqsFilterMessagesWithNoDeleteTest extends TestSupport { ctx.start(); // the message should get through filter and mock should assert this - assertIsSatisfied(1000, TimeUnit.MILLISECONDS); + assertIsSatisfied(2000, TimeUnit.MILLISECONDS); // however, the message should not be deleted, that is, it should be left on the queue String response = ctx.createConsumerTemplate().receiveBody(sqsURI, 5000, String.class); http://git-wip-us.apache.org/repos/asf/camel/blob/25ce6437/components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/ManagedNettyEndpointTest.java ---------------------------------------------------------------------- diff --git a/components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/ManagedNettyEndpointTest.java b/components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/ManagedNettyEndpointTest.java index 986c1b7..a59d8ee 100644 --- a/components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/ManagedNettyEndpointTest.java +++ b/components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/ManagedNettyEndpointTest.java @@ -52,9 +52,9 @@ public class ManagedNettyEndpointTest extends BaseNettyTest { return; } - // should not add 100 endpoints - getMockEndpoint("mock:foo").expectedMessageCount(100); - for (int i = 0; i < 100; i++) { + // should not add 10 endpoints + getMockEndpoint("mock:foo").expectedMessageCount(10); + for (int i = 0; i < 10; i++) { String out = template.requestBody("netty-http:http://localhost:{{port}}/foo?param"; + i + "=value" + i, "Hello World", String.class); assertEquals("param" + i + "=value" + i, out); }
