You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by cm...@apache.org on 2012/08/08 23:24:14 UTC

svn commit: r1370979 - /camel/trunk/camel-core/src/test/java/org/apache/camel/component/directvm/DirectVmConsumerExpressionTest.java

Author: cmueller
Date: Wed Aug  8 21:24:14 2012
New Revision: 1370979

URL: http://svn.apache.org/viewvc?rev=1370979&view=rev
Log:
added a negative test for DirectVmConsumerExpressionTest

Modified:
    camel/trunk/camel-core/src/test/java/org/apache/camel/component/directvm/DirectVmConsumerExpressionTest.java

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/directvm/DirectVmConsumerExpressionTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/directvm/DirectVmConsumerExpressionTest.java?rev=1370979&r1=1370978&r2=1370979&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/component/directvm/DirectVmConsumerExpressionTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/directvm/DirectVmConsumerExpressionTest.java Wed Aug  8 21:24:14 2012
@@ -32,6 +32,7 @@ public class DirectVmConsumerExpressionT
 
     private CamelContext context2;
     private CamelContext context3;
+    private CamelContext context4;
 
     @Override
     @Before
@@ -40,9 +41,11 @@ public class DirectVmConsumerExpressionT
 
         context2 = new DefaultCamelContext();
         context3 = new DefaultCamelContext();
+        context4 = new DefaultCamelContext();
 
         ServiceHelper.startServices(context2);
         ServiceHelper.startServices(context3);
+        ServiceHelper.startServices(context4);
 
         // add routes after CamelContext has been started
         RouteBuilder routeBuilder = createRouteBuilderCamelContext2();
@@ -54,12 +57,17 @@ public class DirectVmConsumerExpressionT
         if (routeBuilder != null) {
             context3.addRoutes(routeBuilder);
         }
+        
+        routeBuilder = createRouteBuilderCamelContext4();
+        if (routeBuilder != null) {
+            context4.addRoutes(routeBuilder);
+        }
     }
 
     @Override
     @After
     protected void tearDown() throws Exception {
-        ServiceHelper.stopServices(context2, context3);
+        ServiceHelper.stopServices(context2, context3, context4);
         super.tearDown();
     }
 
@@ -69,11 +77,15 @@ public class DirectVmConsumerExpressionT
 
         MockEndpoint result3 = context3.getEndpoint("mock:result3", MockEndpoint.class);
         result3.expectedBodiesReceived("Hello World");
+        
+        MockEndpoint result4 = context4.getEndpoint("mock:result4", MockEndpoint.class);
+        result4.expectedMessageCount(0);
 
         template.sendBody("direct:start", "Hello World");
 
         MockEndpoint.assertIsSatisfied(context2);
         MockEndpoint.assertIsSatisfied(context3);
+        MockEndpoint.assertIsSatisfied(context4);
     }
 
     @Override
@@ -107,4 +119,13 @@ public class DirectVmConsumerExpressionT
         };
     }
 
+    private RouteBuilder createRouteBuilderCamelContext4() {
+        return new RouteBuilder() {
+            @Override
+            public void configure() throws Exception {
+                from("direct-vm:parent/child/ctx4")
+                    .to("mock:result4");
+            }
+        };
+    }
 }