org.apache.axis2.transport.testkit.tests.misc
Class MinConcurrencyTest

java.lang.Object
  extended by junit.framework.Assert
      extended by junit.framework.TestCase
          extended by org.apache.axis2.transport.testkit.tests.ManagedTestCase
              extended by org.apache.axis2.transport.testkit.tests.misc.MinConcurrencyTest
All Implemented Interfaces:
junit.framework.Test

public class MinConcurrencyTest
extends ManagedTestCase

Generic test case to check whether a transport listener processes messages with the expected level of concurrency. This test case is used to verify that the listener is able to process messages simultaneously.

The test case deploys a given number of services and sends a configurable number of messages to each of these services. The services are configured with a custom message receiver that blocks until the expected level of concurrency (given by the number of endpoints times the number of messages) is reached. If after some timeout the concurrency level is not reached, the test fails.


Constructor Summary
MinConcurrencyTest(AsyncChannel[] channels, int messages, boolean preloadMessages, java.lang.Object... resources)
           
 
Method Summary
protected  void runTest()
           
 
Methods inherited from class org.apache.axis2.transport.testkit.tests.ManagedTestCase
addResource, getId, getName, getNameComponents, getResourceSet, getTestClass, init, setUp, tearDown, toString
 
Methods inherited from class junit.framework.TestCase
countTestCases, createResult, run, run, runBare, setName
 
Methods inherited from class junit.framework.Assert
assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertTrue, assertTrue, fail, fail, failNotEquals, failNotSame, failSame
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

MinConcurrencyTest

public MinConcurrencyTest(AsyncChannel[] channels,
                          int messages,
                          boolean preloadMessages,
                          java.lang.Object... resources)
Method Detail

runTest

protected void runTest()
                throws java.lang.Throwable
Overrides:
runTest in class junit.framework.TestCase
Throws:
java.lang.Throwable


Copyright © 2004-2009 The Apache Software Foundation. All Rights Reserved.