java.lang.Object
junit.framework.Assert
junit.framework.TestCase
org.activemq.store.journal.JournalBrokerBenchmark
- All Implemented Interfaces:
- junit.framework.Test
- public class JournalBrokerBenchmark
- extends junit.framework.TestCase
Benchmarks the Journal Store by using an embeded broker to add and remove messages from
the store.
Make sure you run with jvm option -server (makes a big difference).
The tests simulate storing 1000 1k jms messages to see the rate of
processing msg/sec.
- Version:
- $Revision: 1.1 $
| Fields inherited from class junit.framework.TestCase |
|
|
Method Summary |
static void |
main(java.lang.String[] args)
|
protected void |
setUp()
Sets up the fixture, for example, open a network connection. |
protected void |
tearDown()
Tears down the fixture, for example, close a network connection. |
void |
testConcurrentSendReceive()
Moves about 6000 msg/sec on a Win XP 3.2 ghz Intel Machine. |
| 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 |
MESSAGE_COUNT
private static final int MESSAGE_COUNT
broker
private org.activemq.broker.impl.BrokerContainerImpl broker
dest
private org.activemq.message.ActiveMQQueue dest
connectionFactory
private org.activemq.ActiveMQConnectionFactory connectionFactory
JournalBrokerBenchmark
public JournalBrokerBenchmark()
main
public static void main(java.lang.String[] args)
setUp
protected void setUp()
throws java.lang.Exception
- Description copied from class:
junit.framework.TestCase
- Sets up the fixture, for example, open a network connection.
This method is called before a test is executed.
tearDown
protected void tearDown()
throws java.lang.Exception
- Description copied from class:
junit.framework.TestCase
- Tears down the fixture, for example, close a network connection.
This method is called after a test is executed.
testConcurrentSendReceive
public void testConcurrentSendReceive()
throws java.lang.Throwable
- Moves about 6000 msg/sec on a Win XP 3.2 ghz Intel Machine.