Author: davsclaus
Date: Thu Apr 14 18:36:17 2011
New Revision: 1092433
URL: http://svn.apache.org/viewvc?rev=1092433&view=rev
Log:
Fixed test
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/issues/MulticastParallelStopOnExceptionWithOnExceptionIssueTest.java
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/issues/MulticastParallelStopOnExceptionWithOnExceptionIssueTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/MulticastParallelStopOnExceptionWithOnExceptionIssueTest.java?rev=1092433&r1=1092432&r2=1092433&view=diff
==============================================================================
---
camel/trunk/camel-core/src/test/java/org/apache/camel/issues/MulticastParallelStopOnExceptionWithOnExceptionIssueTest.java
(original)
+++
camel/trunk/camel-core/src/test/java/org/apache/camel/issues/MulticastParallelStopOnExceptionWithOnExceptionIssueTest.java
Thu Apr 14 18:36:17 2011
@@ -45,6 +45,25 @@ public class MulticastParallelStopOnExce
assertMockEndpointsSatisfied();
}
+ public void testEnd2FailureTest() throws Exception {
+ MockEndpoint end2 = getMockEndpoint("mock:end2");
+ end2.whenAnyExchangeReceived(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ throw new RuntimeException("Simulated Exception");
+ }
+ });
+
+ // we run in parallel so the task could have been submitted so we
either get 0 or 1 messages at mock:end2
+ getMockEndpoint("mock:end1").expectedMinimumMessageCount(0);
+ getMockEndpoint("mock:end3").expectedMessageCount(0);
+ getMockEndpoint("mock:end4").expectedMessageCount(1);
+
+ String result = template.requestBody("direct:start", "Hello World!",
String.class);
+ assertEquals("Stop!", result);
+
+ assertMockEndpointsSatisfied();
+ }
+
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() {
