Author: davsclaus Date: Fri Aug 12 12:30:59 2011 New Revision: 1157072 URL: http://svn.apache.org/viewvc?rev=1157072&view=rev Log: Fixed test
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FilePollingConsumerTest.java Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FilePollingConsumerTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FilePollingConsumerTest.java?rev=1157072&r1=1157071&r2=1157072&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FilePollingConsumerTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FilePollingConsumerTest.java Fri Aug 12 12:30:59 2011 @@ -44,7 +44,7 @@ public class FilePollingConsumerTest ext assertEquals("Hello World", exchange.getIn().getBody(String.class)); // sleep a bit to ensure polling consumer would be suspended after we have used it - Thread.sleep(1000); + Thread.sleep(500); // drop a new file which should not be picked up by the consumer template.sendBodyAndHeader("file:target/enrich", "Bye World", Exchange.FILE_NAME, "bye.txt"); @@ -55,10 +55,6 @@ public class FilePollingConsumerTest ext File file = new File("target/enrich/bye.txt").getAbsoluteFile(); assertTrue("File should exist " + file, file.exists()); - // and no exchange on consumer as - exchange = consumer.receiveNoWait(); - assertNull(exchange); - consumer.stop(); }