Author: davsclaus Date: Sat Nov 10 11:30:04 2012 New Revision: 1407764 URL: http://svn.apache.org/viewvc?rev=1407764&view=rev Log: Fixed test on slow CI servers
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerTemplateTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/resequencer/ResequencerEngineTest.java Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerTemplateTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerTemplateTest.java?rev=1407764&r1=1407763&r2=1407764&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerTemplateTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/impl/DefaultConsumerTemplateTest.java Sat Nov 10 11:30:04 2012 @@ -73,7 +73,7 @@ public class DefaultConsumerTemplateTest template.sendBody("seda:foo", "Hello"); // a little delay to let the consumer see it - Thread.sleep(200); + Thread.sleep(500); out = consumer.receiveNoWait("seda:foo"); assertEquals("Hello", out.getIn().getBody()); @@ -118,7 +118,7 @@ public class DefaultConsumerTemplateTest template.sendBody("seda:foo", "Hello"); // a little delay to let the consumer see it - Thread.sleep(200); + Thread.sleep(500); body = consumer.receiveBodyNoWait("seda:foo"); assertEquals("Hello", body); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/resequencer/ResequencerEngineTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/resequencer/ResequencerEngineTest.java?rev=1407764&r1=1407763&r2=1407764&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/resequencer/ResequencerEngineTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/resequencer/ResequencerEngineTest.java Sat Nov 10 11:30:04 2012 @@ -148,6 +148,13 @@ public class ResequencerEngineTest exten resequencer = new ResequencerEngineSync<Integer>(engine); runner = new ResequencerRunner<Integer>(resequencer, 50); runner.start(); + + // give the runner time to start + try { + Thread.sleep(500); + } catch (InterruptedException e) { + // ignore + } } }