public class MinConcurrencyTest extends ManagedTestCase
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 and Description |
---|
MinConcurrencyTest(AsyncChannel[] channels,
int messages,
boolean preloadMessages,
Object... resources) |
Modifier and Type | Method and Description |
---|---|
protected void |
runTest() |
addResource, getId, getName, getNameComponents, getResourceSet, getTestClass, init, setUp, tearDown, toString
countTestCases, createResult, run, run, runBare, setName
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, format
public MinConcurrencyTest(AsyncChannel[] channels, int messages, boolean preloadMessages, Object... resources)
Copyright © 2004-2015 The Apache Software Foundation. All Rights Reserved.