Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.usecases
Class ConsumeTopicPrefetchTest  view ConsumeTopicPrefetchTest download ConsumeTopicPrefetchTest.java

java.lang.Object
  extended byjunit.framework.Assert
      extended byjunit.framework.TestCase
          extended byorg.activemq.test.TestSupport
              extended byorg.activemq.test.ProducerConsumerTestSupport
                  extended byorg.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 $

Field Summary
protected  long consumerTimeout
           
protected  java.lang.String[] messageTexts
           
protected  int prefetchSize
           
 
Fields inherited from class org.activemq.test.ProducerConsumerTestSupport
connection, consumer, destination, producer, session
 
Fields inherited from class org.activemq.test.TestSupport
connectionFactory, log, topic
 
Fields inherited from class junit.framework.TestCase
 
Constructor Summary
ConsumeTopicPrefetchTest()
           
 
Method Summary
protected  void consumeMessge(int i)
           
protected  javax.jms.Connection createConnection()
          Factory method to create a new connection
protected  void makeMessages(int messageCount)
           
 void testSendDoublePrefetchSize()
           
 void testSendPrefetchSize()
           
 void testSendPrefetchSizePlusOne()
           
protected  void testWithMessageCount(int messageCount)
           
 
Methods inherited from class org.activemq.test.ProducerConsumerTestSupport
setUp, tearDown
 
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.TestCase
countTestCases, createResult, getName, run, run, runBare, 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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

prefetchSize

protected int prefetchSize

messageTexts

protected java.lang.String[] messageTexts

consumerTimeout

protected long consumerTimeout
Constructor Detail

ConsumeTopicPrefetchTest

public ConsumeTopicPrefetchTest()
Method Detail

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)