Author: davsclaus
Date: Sun Sep 28 00:57:50 2008
New Revision: 699776
URL: http://svn.apache.org/viewvc?rev=699776&view=rev
Log:
CAMEL-927: Added unit test with multiple from in the same route
Added:
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/MultipleFromTest.java
(contents, props changed)
- copied, changed from r699774,
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/TwoTimerWithJMSIssue.java
Copied:
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/MultipleFromTest.java
(from r699774,
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/TwoTimerWithJMSIssue.java)
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/MultipleFromTest.java?p2=activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/MultipleFromTest.java&p1=activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/TwoTimerWithJMSIssue.java&r1=699774&r2=699776&rev=699776&view=diff
==============================================================================
---
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/TwoTimerWithJMSIssue.java
(original)
+++
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/MultipleFromTest.java
Sun Sep 28 00:57:50 2008
@@ -19,23 +19,19 @@
import org.apache.camel.ContextTestSupport;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.processor.interceptor.Tracer;
/**
- * Trying to reproduce CAMEL-927.
+ * Testing routes having multiple from in the same route.
*/
-public class TwoTimerWithJMSIssue extends ContextTestSupport {
+public class MultipleFromTest extends ContextTestSupport {
- @Override
- protected void setUp() throws Exception {
- //disableJMX(); in case JMX is the culprint
- super.setUp();
- }
-
- public void testTimer() throws Exception {
+ public void testMultipleFrom() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
- // we expect 4 messages to let the timers fire twice
- mock.expectedMinimumMessageCount(4);
+ mock.expectedMessageCount(2);
+ mock.expectedBodiesReceived("Hello World", "Bye World");
+
+ template.sendBody("direct:start", "Hello World");
+ template.sendBody("seda:in", "Bye World");
assertMockEndpointsSatisfied();
}
@@ -44,12 +40,9 @@
protected RouteBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() {
public void configure() throws Exception {
- context.addInterceptStrategy(new Tracer());
-
-
from("timer://kickoff_1?period=2000&delay=1").to("mock:result");
-
-
from("timer://kickoff_2?period=2000&delay=2").to("mock:result");
+ from("direct:start").from("seda:in").to("mock:result");
}
};
}
-}
+
+}
\ No newline at end of file
Propchange:
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/MultipleFromTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/MultipleFromTest.java
------------------------------------------------------------------------------
svn:keywords = Rev Date
Propchange:
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/MultipleFromTest.java
------------------------------------------------------------------------------
svn:mergeinfo =
