Repository: camel Updated Branches: refs/heads/camel-2.12.x 6de2fba64 -> 90685ddb3 refs/heads/master 5621bd3d8 -> 8ace0ebc0
Fixed test on slower CI box Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a97dbc25 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a97dbc25 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a97dbc25 Branch: refs/heads/master Commit: a97dbc25007eed9edfea27be2c6759b2ec7158a8 Parents: cb185c6 Author: Claus Ibsen <davscl...@apache.org> Authored: Mon Feb 24 15:26:24 2014 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon Feb 24 17:05:27 2014 +0100 ---------------------------------------------------------------------- .../apache/camel/support/DefaultTimeoutMapTest.java | 15 +++++++++++++++ 1 file changed, 15 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/a97dbc25/camel-core/src/test/java/org/apache/camel/support/DefaultTimeoutMapTest.java ---------------------------------------------------------------------- diff --git a/camel-core/src/test/java/org/apache/camel/support/DefaultTimeoutMapTest.java b/camel-core/src/test/java/org/apache/camel/support/DefaultTimeoutMapTest.java index fcf52b8..731c6e7 100644 --- a/camel-core/src/test/java/org/apache/camel/support/DefaultTimeoutMapTest.java +++ b/camel-core/src/test/java/org/apache/camel/support/DefaultTimeoutMapTest.java @@ -23,12 +23,15 @@ import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledThreadPoolExecutor; import junit.framework.TestCase; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * @version */ public class DefaultTimeoutMapTest extends TestCase { + private static final Logger LOG = LoggerFactory.getLogger(DefaultTimeoutMapTest.class); private ScheduledExecutorService executor = new ScheduledThreadPoolExecutor(1); public void testDefaultTimeoutMap() throws Exception { @@ -52,6 +55,10 @@ public class DefaultTimeoutMapTest extends TestCase { assertEquals(1, map.size()); Thread.sleep(250); + if (map.size() > 0) { + LOG.warn("Waiting extra due slow CI box"); + Thread.sleep(1000); + } assertEquals(0, map.size()); @@ -124,6 +131,10 @@ public class DefaultTimeoutMapTest extends TestCase { Thread.sleep(250); + if (map.size() > 0) { + LOG.warn("Waiting extra due slow CI box"); + Thread.sleep(1000); + } // should have been timed out now assertEquals(0, map.size()); @@ -239,6 +250,10 @@ public class DefaultTimeoutMapTest extends TestCase { // start and wait for scheduler to purge Thread.sleep(250); + if (map.size() > 0) { + LOG.warn("Waiting extra due slow CI box"); + Thread.sleep(1000); + } // now it should be gone assertEquals(0, map.size());