svn commit: r370237 - /incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/tck/TestSupport.java

[gn...@apache.org]

Author: gnodet
Date: Wed Jan 18 11:50:07 2006
New Revision: 370237

URL: http://svn.apache.org/viewcvs?rev=370237&view=rev
Log:
Add async send on TestSupport

Modified:
    incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/tck/TestSupport.java

Modified: incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/tck/TestSupport.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/tck/TestSupport.java?rev=370237&r1=370236&r2=370237&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/tck/TestSupport.java (original)
+++ incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/tck/TestSupport.java Wed Jan 18 11:50:07 2006
@@ -59,13 +59,17 @@
         assertMessagesReceived(messageCount);
     }
 
+    protected void sendMessages(QName service, int messageCount) throws Exception {
+    	sendMessages(service, messageCount, true);
+    }
+    
     /**
      * Sends the given number of messages to the given service
      *
      * @param service
      * @throws javax.jbi.messaging.MessagingException
      */
-    protected void sendMessages(QName service, int messageCount) throws Exception {
+    protected void sendMessages(QName service, int messageCount, boolean sync) throws Exception {
         for (int i = 1; i <= messageCount; i++) {
             InOnly exchange = client.createInOnlyExchange();
 
@@ -76,7 +80,11 @@
             message.setContent(new StringSource(createMessageXmlText(i)));
 
             exchange.setService(service);
-            client.sendSync(exchange);
+            if (sync) {
+            	client.sendSync(exchange);
+            } else {
+            	client.send(exchange);
+            }
 
             // lets assert that we have no failure
             Exception error = exchange.getError();