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 2010/06/20 09:31:24 UTC
svn commit: r956322 -
/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterStreamCacheTest.java
Author: davsclaus
Date: Sun Jun 20 07:31:23 2010
New Revision: 956322
URL: http://svn.apache.org/viewvc?rev=956322&view=rev
Log:
Fixed test on other platforms.
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterStreamCacheTest.java
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterStreamCacheTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterStreamCacheTest.java?rev=956322&r1=956321&r2=956322&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterStreamCacheTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SplitterStreamCacheTest.java Sun Jun 20 07:31:23 2010
@@ -31,7 +31,7 @@ import org.apache.camel.converter.stream
public class SplitterStreamCacheTest extends ContextTestSupport {
private static final String TEST_FILE = "org/apache/camel/converter/stream/test.xml";
- protected int numMessages = 1000;
+ protected int numMessages = 200;
public void testSendStreamSource() throws Exception {
MockEndpoint resultEndpoint = getMockEndpoint("mock:result");
@@ -50,7 +50,10 @@ public class SplitterStreamCacheTest ext
//ensure stream is spooled to disk
getContext().getProperties().put(CachedOutputStream.TEMP_DIR, "target/tmp");
getContext().getProperties().put(CachedOutputStream.THRESHOLD, "1");
- from("seda:parallel?size=1000&concurrentConsumers=5").streamCaching().split(XPathBuilder.xpath("//person/city")).to("mock:result");
+
+ from("seda:parallel?concurrentConsumers=5").streamCaching()
+ .split(XPathBuilder.xpath("//person/city"))
+ .to("mock:result");
}
};
}