Author: davsclaus
Date: Mon Sep 12 08:09:48 2011
New Revision: 1169642
URL: http://svn.apache.org/viewvc?rev=1169642&view=rev
Log:
Added test based on user forum issue
Added:
camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAddDynamicRouteTest.java
- copied, changed from r1169607,
camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzRouteTest.java
Copied:
camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAddDynamicRouteTest.java
(from r1169607,
camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzRouteTest.java)
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAddDynamicRouteTest.java?p2=camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAddDynamicRouteTest.java&p1=camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzRouteTest.java&r1=1169607&r2=1169642&rev=1169642&view=diff
==============================================================================
---
camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzRouteTest.java
(original)
+++
camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAddDynamicRouteTest.java
Mon Sep 12 08:09:48 2011
@@ -24,17 +24,30 @@ import org.junit.Test;
/**
* @version
*/
-public class QuartzRouteTest extends CamelTestSupport {
+public class QuartzAddDynamicRouteTest extends CamelTestSupport {
protected MockEndpoint resultEndpoint;
@Test
- public void testQuartzRoute() throws Exception {
+ public void testAddDynamicRoute() throws Exception {
resultEndpoint = getMockEndpoint("mock:result");
+ resultEndpoint.expectedMessageCount(1);
+
+ template.sendBody("direct:foo", "Hello World");
+
+ resultEndpoint.assertIsSatisfied();
+
+ // reset and add a new dynamic route
+ resultEndpoint.reset();
resultEndpoint.expectedMessageCount(2);
-
resultEndpoint.message(0).header("triggerName").isEqualTo("myTimerName");
- resultEndpoint.message(0).header("triggerGroup").isEqualTo("myGroup");
- // lets test the receive worked
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+
from("quartz://myGroup/myTimerName?trigger.repeatInterval=2&trigger.repeatCount=1").routeId("myRoute")
+ .to("direct:foo");
+ }
+ });
+
resultEndpoint.assertIsSatisfied();
}
@@ -42,9 +55,7 @@ public class QuartzRouteTest extends Cam
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
- // START SNIPPET: example
-
from("quartz://myGroup/myTimerName?trigger.repeatInterval=2&trigger.repeatCount=1").routeId("myRoute").to("mock:result");
- // END SNIPPET: example
+ from("direct:foo").to("mock:result");
}
};
}