Package org.apache.axis2.transport.testkit.tests.misc

Class MinConcurrencyTest

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

org.apache.axis2.transport.testkit.tests.ManagedTestCase

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

Constructors

Constructor	Description
MinConcurrencyTest(AsyncChannel[] channels, int messages, boolean preloadMessages, Object... resources)

Method Summary

Modifier and Type	Method	Description
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

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, countTestCases, createResult, fail, fail, failNotEquals, failNotSame, failSame, format, run, run, runBare, setName

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,
                          Object... resources)

Method Detail

runTest

protected void runTest()
                throws Throwable

Overrides:

runTest in class junit.framework.TestCase

Throws:

Throwable