svn commit: r697403 - in /synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit: client/axis2/AxisAsyncTestClient.java tests/misc/MinConcurrencyTest.java

[veithen]

Author: veithen
Date: Sat Sep 20 11:19:02 2008
New Revision: 697403

URL: http://svn.apache.org/viewvc?rev=697403&view=rev
Log:
Transport test kit: Make the AxisAsyncTestClient blocking by default. This 
should solve some random failures in the VFS transport tests.

Modified:
    
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/client/axis2/AxisAsyncTestClient.java
    
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/misc/MinConcurrencyTest.java

Modified: 
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/client/axis2/AxisAsyncTestClient.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/client/axis2/AxisAsyncTestClient.java?rev=697403&r1=697402&r2=697403&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/client/axis2/AxisAsyncTestClient.java
 (original)
+++ 
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/client/axis2/AxisAsyncTestClient.java
 Sat Sep 20 11:19:02 2008
@@ -27,7 +27,17 @@
 import org.apache.synapse.transport.testkit.message.AxisMessage;
 
 public class AxisAsyncTestClient extends AxisTestClient implements 
AsyncTestClient<AxisMessage> {
+    private final boolean block;
+    
+    public AxisAsyncTestClient(boolean block) {
+        this.block = block;
+    }
+
+    public AxisAsyncTestClient() {
+        this(true);
+    }
+
     public void sendMessage(ClientOptions options, ContentType contentType, 
AxisMessage message) throws Exception {
-        createClient(options, message, 
ServiceClient.ANON_OUT_ONLY_OP).execute(false);
+        createClient(options, message, 
ServiceClient.ANON_OUT_ONLY_OP).execute(block);
     }
 }

Modified: 
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/misc/MinConcurrencyTest.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/misc/MinConcurrencyTest.java?rev=697403&r1=697402&r2=697403&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/misc/MinConcurrencyTest.java
 (original)
+++ 
synapse/trunk/java/modules/transports/src/test/java/org/apache/synapse/transport/testkit/tests/misc/MinConcurrencyTest.java
 Sat Sep 20 11:19:02 2008
@@ -97,7 +97,7 @@
                 TestResourceSet clientResourceSet = new 
TestResourceSet(getResourceSet());
                 AsyncChannel channel = channels[i];
                 clientResourceSet.addResource(channel);
-                AxisAsyncTestClient client = new AxisAsyncTestClient();
+                AxisAsyncTestClient client = new AxisAsyncTestClient(false);
                 clientResourceSet.addResource(client);
                 clientResourceSet.setUp();
                 clientResourceSets[i] = clientResourceSet;