svn commit: r1392922 - /camel/trunk/camel-core/src/test/java/org/apache/camel/processor/onexception/DoCatchDirectRouteTest.java

[davsclaus]

Author: davsclaus
Date: Tue Oct  2 14:16:25 2012
New Revision: 1392922

URL: http://svn.apache.org/viewvc?rev=1392922&view=rev
Log:
Added test base on user forum issue

Added:
    
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/onexception/DoCatchDirectRouteTest.java
      - copied, changed from r1392749, 
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/onexception/OnCatchHandledTest.java

Copied: 
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/onexception/DoCatchDirectRouteTest.java
 (from r1392749, 
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/onexception/OnCatchHandledTest.java)
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/onexception/DoCatchDirectRouteTest.java?p2=camel/trunk/camel-core/src/test/java/org/apache/camel/processor/onexception/DoCatchDirectRouteTest.java&p1=camel/trunk/camel-core/src/test/java/org/apache/camel/processor/onexception/OnCatchHandledTest.java&r1=1392749&r2=1392922&rev=1392922&view=diff
==============================================================================
--- 
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/onexception/OnCatchHandledTest.java
 (original)
+++ 
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/onexception/DoCatchDirectRouteTest.java
 Tue Oct  2 14:16:25 2012
@@ -16,12 +16,22 @@
  */
 package org.apache.camel.processor.onexception;
 
+import org.apache.camel.ContextTestSupport;
 import org.apache.camel.builder.RouteBuilder;
 
 /**
  * @version 
  */
-public class OnCatchHandledTest extends OnExceptionHandledTest {
+public class DoCatchDirectRouteTest extends ContextTestSupport {
+
+    public void testDoCatchDirectRoute() throws Exception {
+        getMockEndpoint("mock:a").expectedMessageCount(1);
+        getMockEndpoint("mock:b").expectedMessageCount(1);
+
+        template.sendBody("direct:start", "Hello World");
+
+        assertMockEndpointsSatisfied();
+    }
 
     @Override
     protected RouteBuilder createRouteBuilder() throws Exception {
@@ -30,10 +40,17 @@ public class OnCatchHandledTest extends 
             public void configure() throws Exception {
                 from("direct:start")
                     .doTry()
-                        .throwException(new IllegalArgumentException("Forced"))
-                    .doCatch(IllegalArgumentException.class)
-                        .to("log:foo?showAll=true").to("mock:handled")
+                        .to("direct:a")
+                    .doCatch(Exception.class)
+                        .to("direct:b")
                     .end();
+
+                from("direct:a")
+                    .to("mock:a")
+                    .throwException(new IllegalArgumentException("Forced"));
+
+                from("direct:b")
+                    .to("mock:b");
             }
         };
     }