|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjunit.framework.Assert
junit.framework.TestCase
org.apache.qpid.test.utils.QpidTestCase
org.apache.qpid.test.utils.QpidBrokerTestCase
org.apache.qpid.test.framework.FrameworkBaseCase
org.apache.qpid.test.testcases.MessageThroughputPerf
public class MessageThroughputPerf
MessageThroughputPerf runs a test over a Circuit
controlled by the test parameters. It logs timings of
the time required to receive samples consisting of batches of messages.
Responsibilities | Collaborations |
---|---|
Measure message throughput accross a test circuit. | Circuit
|
Nested Class Summary | |
---|---|
protected static class |
MessageThroughputPerf.PerThreadSetup
Holds the per-thread test configurations. |
Nested classes/interfaces inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase |
---|
org.apache.qpid.test.utils.QpidBrokerTestCase.MessageType |
Field Summary | |
---|---|
(package private) ThreadLocal<MessageThroughputPerf.PerThreadSetup> |
threadSetup
Thread local to hold the per-thread test setup fields. |
Fields inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase |
---|
_broker, _brokerLanguage, _brokerLogPrefix, _brokerOutputStream, _brokerPersistent, _brokers, _configFile, _connectionFactory, _connections, _initialContext, _interleaveBrokerLog, _logger, _output, _outputFile, _testName, BROKER_READY, CONTENT, CPP, DEFAULT_MANAGEMENT_PORT, DEFAULT_MESSAGE_SIZE, DEFAULT_PORT, DEFAULT_SSL_PORT, DEFAULT_VM_PORT, EXTERNAL, INDEX, JAVA, LOGMONITOR_TIMEOUT, QPID_HOME, QpidHome, QUEUE, RECEIVE_TIMEOUT, TOPIC, VM |
Fields inherited from class org.apache.qpid.test.utils.QpidTestCase |
---|
MEMORY_STORE_CLASS_NAME, MS_CLASS_NAME_KEY |
Constructor Summary | |
---|---|
MessageThroughputPerf(String name)
Creates a new test case with the specified name. |
Method Summary | |
---|---|
String |
getTestCaseNameForTestMethod(String methodName)
Should provide a translation from the junit method name of a test to its test case name as known to the test clients that will run the test. |
void |
postThreadSetUp()
Called after all threads have completed their setup. |
void |
setTimingController(org.apache.qpid.junit.extensions.TimingController controller)
Used by test runners that can supply a TimingController to set the
controller on an aware test. |
protected void |
setUp()
Overrides the parent setUp method so that the in-vm broker creation is not done on a per test basis. |
static junit.framework.Test |
suite()
Compiles all the tests in this class into a suite. |
protected void |
tearDown()
Overrides the parent setUp method so that the in-vm broker clean-up is not done on a per test basis. |
void |
testThroughput(int numMessages)
Performs the a basic P2P test case. |
void |
threadSetUp()
Performs test fixture creation on a per thread basis. |
void |
threadTearDown()
Called when a test thread is destroyed. |
Methods inherited from class org.apache.qpid.test.framework.FrameworkBaseCase |
---|
assertionList, assertionsToString, assertNoFailures, chainSetupTask, chainTearDownTask, getCircuitFactory, getFailureMechanism, getLiveBroker, getTaskHandler, getTestCaseVector, getTestParameters, getTestProps, setCircuitFactory, setFailureMechanism, setInVmBrokers, setLiveBroker, setTestProps, usingInVmBroker |
Methods inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase |
---|
cleanBroker, createMessage, createNextMessage, drainQueue, getBroker, getBrokerCommand, getClientConnection, getConfigurationStringProperty, getConnection, getConnection, getConnection, getConnectionFactory, getConnectionFactory, getConnectionURL, getInitialContext, getLogger, getManagementPort, getMessageSize, getPort, getPort, getTestConfigFile, getTestQueue, getTestQueueName, getTestVirtualhostsFile, isBroker010, isBroker08, isBrokerStorePersistent, isCppBroker, isExternalBroker, isJavaBroker, makeVirtualHostPersistent, reloadBrokerSecurityConfig, restartBroker, restartBroker, revertLoggingLevels, revertSystemProperties, runBare, saveTestConfiguration, saveTestVirtualhosts, sendMessage, sendMessage, sendMessage, setBrokerEnvironment, setBrokerOnlySystemProperty, setConfigurationProperty, setLoggerLevel, setMessageSize, setSystemProperty, setSystemProperty, setTestClientSystemProperty, startBroker, startBroker, stopBroker, stopBroker |
Methods inherited from class org.apache.qpid.test.utils.QpidTestCase |
---|
getTestProfileMessageStoreClassName, run |
Methods inherited from class junit.framework.TestCase |
---|
countTestCases, createResult, getName, run, runTest, setName, toString |
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 |
Field Detail |
---|
ThreadLocal<MessageThroughputPerf.PerThreadSetup> threadSetup
Constructor Detail |
---|
public MessageThroughputPerf(String name)
name
- The test case name.Method Detail |
---|
public void testThroughput(int numMessages)
numMessages
- The number of messages to send in the test.public String getTestCaseNameForTestMethod(String methodName)
getTestCaseNameForTestMethod
in class org.apache.qpid.test.framework.FrameworkBaseCase
methodName
- The name of the JUnit test method.
public void setTimingController(org.apache.qpid.junit.extensions.TimingController controller)
TimingController
to set the
controller on an aware test.
setTimingController
in interface org.apache.qpid.junit.extensions.TimingControllerAware
controller
- The timing controller.protected void setUp() throws Exception
setUp
in class org.apache.qpid.test.framework.FrameworkBaseCase
Exception
- Any exceptions allowed to fall through and fail the test.protected void tearDown()
tearDown
in class org.apache.qpid.test.framework.FrameworkBaseCase
public void threadSetUp()
threadSetUp
in interface org.apache.qpid.junit.extensions.TestThreadAware
public void postThreadSetUp()
postThreadSetUp
in interface org.apache.qpid.junit.extensions.TestThreadAware
public void threadTearDown()
threadTearDown
in interface org.apache.qpid.junit.extensions.TestThreadAware
public static junit.framework.Test suite()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |