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 2011/08/12 14:31:00 UTC
svn commit: r1157072 -
/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FilePollingConsumerTest.java
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();
}