Author: davsclaus Date: Thu Jun 17 04:27:52 2010 New Revision: 955478 URL: http://svn.apache.org/viewvc?rev=955478&view=rev Log: CAMEL-2723: Fixed test.
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ExceptionHandlerStreamCacheTest.java Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ExceptionHandlerStreamCacheTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ExceptionHandlerStreamCacheTest.java?rev=955478&r1=955477&r2=955478&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ExceptionHandlerStreamCacheTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ExceptionHandlerStreamCacheTest.java Thu Jun 17 04:27:52 2010 @@ -30,7 +30,6 @@ import org.apache.camel.builder.RouteBui import org.apache.camel.component.mock.MockEndpoint; import org.apache.camel.converter.IOConverter; import org.apache.camel.converter.jaxp.XmlConverter; -import org.apache.camel.processor.interceptor.HandleFault; /** * Test cases for dealing with stream types in an exception handler @@ -96,11 +95,13 @@ public class ExceptionHandlerStreamCache return new RouteBuilder() { public void configure() { + // enable support for handling faults and stream caching + context.setHandleFault(true); + context.setStreamCaching(true); + onException(Exception.class).handled(true).to("mock:exception"); - intercept().addInterceptStrategy(new HandleFault()); from("direct:start").process(new Processor() { - public void process(Exchange exchange) throws Exception { String message = exchange.getIn().getBody(String.class); @@ -114,7 +115,6 @@ public class ExceptionHandlerStreamCache throw new RuntimeException(message); } } - }).to("mock:success"); } };