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

Quick Search    Search Deep

org.activemq.test
Class SendReceiveTest  view SendReceiveTest download SendReceiveTest.java

java.lang.Object
  extended byjunit.framework.Assert
      extended byjunit.framework.TestCase
          extended byorg.activemq.test.TestSupport
              extended byorg.activemq.test.JmsSendReceiveTestSupport
                  extended byorg.activemq.test.JmsTopicSendReceiveTest
                      extended byorg.activemq.test.SendReceiveTest
All Implemented Interfaces:
javax.jms.MessageListener, junit.framework.Test
Direct Known Subclasses:
QueueSendReceiveTest

public class SendReceiveTest
extends JmsTopicSendReceiveTest

Version:
$Revision: 1.1.1.1 $

Field Summary
private  CountDown countDown
           
 
Fields inherited from class org.activemq.test.JmsTopicSendReceiveTest
connection
 
Fields inherited from class org.activemq.test.JmsSendReceiveTestSupport
consumer, consumerDestination, consumeSession, data, deliveryMode, doneLatch, durable, messageCount, messages, producer, producerDestination, session, topic, useSeparateSession, verbose
 
Fields inherited from class org.activemq.test.TestSupport
connectionFactory, log
 
Fields inherited from class junit.framework.TestCase
 
Constructor Summary
SendReceiveTest()
           
 
Method Summary
 void onMessage(javax.jms.Message message)
           
protected  void sendSomeMessagesAndCheckTheyAreAllReceived(int numberOfMessages)
           
protected  void sendSomeMessagesReusingTheSameMessageAndCheckTheyAreAllReceived(int numberOfMessages)
           
 void testSendReceive()
           
 void testSendReceiveReusingTheMessageInstance()
           
 
Methods inherited from class org.activemq.test.JmsTopicSendReceiveTest
createConsumer, createConsumerSession, setUp, tearDown
 
Methods inherited from class org.activemq.test.JmsSendReceiveTestSupport
assertMessagesAreReceived, assertMessagesReceivedAreValid, consumeMessage, createConcurrentList, waitForMessagesToBeDelivered
 
Methods inherited from class org.activemq.test.TestSupport
assertEquals, assertEquals, assertEquals, assertTextMessageEqual, assertTextMessagesEqual, assertTextMessagesEqual, createConnection, 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

countDown

private CountDown countDown
Constructor Detail

SendReceiveTest

public SendReceiveTest()
Method Detail

testSendReceive

public void testSendReceive()
                     throws java.lang.Exception
Overrides:
testSendReceive in class JmsSendReceiveTestSupport

testSendReceiveReusingTheMessageInstance

public void testSendReceiveReusingTheMessageInstance()
                                              throws java.lang.Exception

onMessage

public void onMessage(javax.jms.Message message)
Specified by:
onMessage in interface javax.jms.MessageListener
Overrides:
onMessage in class JmsSendReceiveTestSupport

sendSomeMessagesAndCheckTheyAreAllReceived

protected void sendSomeMessagesAndCheckTheyAreAllReceived(int numberOfMessages)
                                                   throws javax.jms.JMSException,
                                                          java.lang.InterruptedException

sendSomeMessagesReusingTheSameMessageAndCheckTheyAreAllReceived

protected void sendSomeMessagesReusingTheSameMessageAndCheckTheyAreAllReceived(int numberOfMessages)
                                                                        throws javax.jms.JMSException,
                                                                               java.lang.InterruptedException