You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2009/05/28 15:47:09 UTC

svn commit: r779604 - /camel/trunk/components/camel-saxon/src/test/java/org/apache/camel/component/xquery/XQueryConcurrencyTest.java

Author: davsclaus
Date: Thu May 28 13:47:09 2009
New Revision: 779604

URL: http://svn.apache.org/viewvc?rev=779604&view=rev
Log:
Added concurrency test.

Modified:
    camel/trunk/components/camel-saxon/src/test/java/org/apache/camel/component/xquery/XQueryConcurrencyTest.java

Modified: camel/trunk/components/camel-saxon/src/test/java/org/apache/camel/component/xquery/XQueryConcurrencyTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-saxon/src/test/java/org/apache/camel/component/xquery/XQueryConcurrencyTest.java?rev=779604&r1=779603&r2=779604&view=diff
==============================================================================
--- camel/trunk/components/camel-saxon/src/test/java/org/apache/camel/component/xquery/XQueryConcurrencyTest.java (original)
+++ camel/trunk/components/camel-saxon/src/test/java/org/apache/camel/component/xquery/XQueryConcurrencyTest.java Thu May 28 13:47:09 2009
@@ -52,14 +52,15 @@
                         } catch (InterruptedException e) {
                             // ignore
                         }
-                        template.sendBody(uri, "<person><id>" + (start + i) + "</id><name>James</name></person>");
+                        template.sendBody(uri, "<person><id>" + (start + i + 1) + "</id><name>James</name></person>");
                     }
                 }
             });
         }
 
-        mock.assertIsSatisfied();
         mock.assertNoDuplicates(body());
+
+        assertMockEndpointsSatisfied();
     }
 
     protected RouteBuilder createRouteBuilder() throws Exception {