Modified: camel/branches/camel-2.8.x/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateSimpleExpressionIssueTest.java URL: http://svn.apache.org/viewvc/camel/branches/camel-2.8.x/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateSimpleExpressionIssueTest.java?rev=1222438&r1=1222437&r2=1222438&view=diff ============================================================================== --- camel/branches/camel-2.8.x/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateSimpleExpressionIssueTest.java (original) +++ camel/branches/camel-2.8.x/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateSimpleExpressionIssueTest.java Thu Dec 22 20:41:32 2011 @@ -16,7 +16,6 @@ */ package org.apache.camel.processor.aggregator; -import java.io.BufferedWriter; import java.io.File; import java.io.FileWriter; import java.io.Writer; @@ -29,6 +28,7 @@ import org.apache.camel.Exchange; import org.apache.camel.builder.NotifyBuilder; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.processor.aggregate.AggregationStrategy; +import org.apache.camel.util.IOHelper; import org.apache.camel.util.StopWatch; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -67,7 +67,7 @@ public class AggregateSimpleExpressionIs LOG.info("Writing 10 files with 100000 rows in each file"); // write 10 files of 100k rows for (int i = 0; i < files; i++) { - Writer out = new BufferedWriter(new FileWriter(new File("target/files", "data" + i))); + Writer out = IOHelper.buffered(new FileWriter(new File("target/files", "data" + i))); for (int j = 0; j < rows; j++) { out.write(DATA); }
Modified: camel/branches/camel-2.8.x/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastInstanceConsumerTest.java URL: http://svn.apache.org/viewvc/camel/branches/camel-2.8.x/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastInstanceConsumerTest.java?rev=1222438&r1=1222437&r2=1222438&view=diff ============================================================================== --- camel/branches/camel-2.8.x/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastInstanceConsumerTest.java (original) +++ camel/branches/camel-2.8.x/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastInstanceConsumerTest.java Thu Dec 22 20:41:32 2011 @@ -32,6 +32,7 @@ import org.junit.Test; public class HazelcastInstanceConsumerTest extends CamelTestSupport { @Test + @Ignore("Causes further hazelast tests to fail") public void testAddInstance() throws InterruptedException { MockEndpoint added = getMockEndpoint("mock:added");
