java.lang.Object
junit.framework.Assert
junit.framework.TestCase
org.activemq.test.TestSupport
org.activemq.test.ProducerConsumerTestSupport
org.activemq.usecases.ConsumeTopicPrefetchTest
- All Implemented Interfaces:
- junit.framework.Test
- Direct Known Subclasses:
- ConsumeQueuePrefetchTest
- public class ConsumeTopicPrefetchTest
- extends org.activemq.test.ProducerConsumerTestSupport
- Version:
- $Revision: 1.1.1.1 $
| Fields inherited from class junit.framework.TestCase |
|
| Methods inherited from class org.activemq.test.TestSupport |
assertEquals, assertEquals, assertEquals, assertTextMessageEqual, assertTextMessagesEqual, assertTextMessagesEqual, createConnectionFactory, createDestination, createMessage, getConnectionFactory, getConsumerSubject, getProducerSubject, getSubject |
| 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 |
prefetchSize
protected int prefetchSize
messageTexts
protected java.lang.String[] messageTexts
consumerTimeout
protected long consumerTimeout
ConsumeTopicPrefetchTest
public ConsumeTopicPrefetchTest()
testSendPrefetchSize
public void testSendPrefetchSize()
throws javax.jms.JMSException
testSendDoublePrefetchSize
public void testSendDoublePrefetchSize()
throws javax.jms.JMSException
testSendPrefetchSizePlusOne
public void testSendPrefetchSizePlusOne()
throws javax.jms.JMSException
testWithMessageCount
protected void testWithMessageCount(int messageCount)
throws javax.jms.JMSException
createConnection
protected javax.jms.Connection createConnection()
throws java.lang.Exception
- Description copied from class:
org.activemq.test.TestSupport
- Factory method to create a new connection
consumeMessge
protected void consumeMessge(int i)
throws javax.jms.JMSException
makeMessages
protected void makeMessages(int messageCount)