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();
     }