Polished test
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f8871a23 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f8871a23 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f8871a23 Branch: refs/heads/master Commit: f8871a2389104cb71280f18b144f367c7dc78058 Parents: 5af0fe4 Author: Claus Ibsen <davscl...@apache.org> Authored: Sun May 10 10:22:13 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sun May 10 10:22:13 2015 +0200 ---------------------------------------------------------------------- .../camel/processor/aggregator/AggregateTimeoutTest.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/f8871a23/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateTimeoutTest.java ---------------------------------------------------------------------- diff --git a/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateTimeoutTest.java b/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateTimeoutTest.java index 27ad9ec..f07003c 100644 --- a/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateTimeoutTest.java +++ b/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateTimeoutTest.java @@ -42,10 +42,8 @@ public class AggregateTimeoutTest extends ContextTestSupport { template.sendBodyAndHeader("direct:start", "A", "id", 123); template.sendBodyAndHeader("direct:start", "B", "id", 123); - // wait 3 seconds so that the timeout kicks in - Thread.sleep(3000); - - mock.assertIsSatisfied(); + // wait about 4 seconds so that the timeout kicks in but it was discarded + mock.assertIsSatisfied(4000); // should invoke the timeout method assertEquals(1, invoked.get());
