You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2013/11/11 09:38:49 UTC
git commit: Fixed test
Updated Branches:
refs/heads/master 8e7393f14 -> f68021041
Fixed test
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f6802104
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f6802104
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f6802104
Branch: refs/heads/master
Commit: f68021041bae94128318ac8641773f0d851e4ce3
Parents: 8e7393f
Author: Claus Ibsen <da...@apache.org>
Authored: Mon Nov 11 09:35:58 2013 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Mon Nov 11 09:38:29 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/f6802104/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/f6802104/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 2dc5454..aff7ed9 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
@@ -48,9 +48,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);
}