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");
+ }
+ };
+ }
}