org.activemq
Class JmsSendReceiveTestSupport

java.lang.Object
junit.framework.Assert
junit.framework.TestCase
org.activemq.TestSupport
org.activemq.JmsSendReceiveTestSupport
- All Implemented Interfaces:
- javax.jms.MessageListener, junit.framework.Test
- Direct Known Subclasses:
- JmsTopicSendReceiveTest, JmsTopicSendReceiveWithTwoConnectionsTest
- public class JmsSendReceiveTestSupport
- extends TestSupport
- implements javax.jms.MessageListener
- Version:
- $Revision: 1.1.1.1 $
| Fields inherited from class junit.framework.TestCase |
|
| Methods inherited from class org.activemq.TestSupport |
assertTextMessagesEqual, createConnection, createConnectionFactory, createDestination, createMessage, getConnectionFactory, getConsumerSubject, getProducerSubject, getSubject, recursiveDelete, removeMessageStore |
| 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 |
messageCount
protected int messageCount
data
protected java.lang.String[] data
session
protected javax.jms.Session session
consumer
protected javax.jms.MessageConsumer consumer
producer
protected javax.jms.MessageProducer producer
consumerDestination
protected javax.jms.Destination consumerDestination
producerDestination
protected javax.jms.Destination producerDestination
messages
protected java.util.List messages
topic
protected boolean topic
durable
protected boolean durable
deliveryMode
protected int deliveryMode
lock
protected final java.lang.Object lock
verbose
protected boolean verbose
JmsSendReceiveTestSupport
public JmsSendReceiveTestSupport()
testSendReceive
public void testSendReceive()
throws java.lang.Exception
assertMessagesAreReceived
protected void assertMessagesAreReceived()
throws javax.jms.JMSException
assertMessagesReceivedAreValid
protected void assertMessagesReceivedAreValid(java.util.List receivedMessages)
throws javax.jms.JMSException
waitForMessagesToBeDelivered
protected void waitForMessagesToBeDelivered()
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.
onMessage
public void onMessage(javax.jms.Message message)
- Specified by:
onMessage in interface javax.jms.MessageListener
consumeMessage
protected void consumeMessage(javax.jms.Message message,
java.util.List messageList)
createConcurrentList
protected java.util.List createConcurrentList()