org.activemq.test
Class QueueMessageStoreTestSupport

java.lang.Object
junit.framework.Assert
junit.framework.TestCase
org.activemq.test.MessageStoreTestSupport
org.activemq.test.QueueMessageStoreTestSupport
- All Implemented Interfaces:
- junit.framework.Test
- public abstract class QueueMessageStoreTestSupport
- extends MessageStoreTestSupport
- Version:
- $Revision: 1.1.1.1 $
| Fields inherited from class org.activemq.test.MessageStoreTestSupport |
ackCount, client, container, destination, idGenerator, messageContainerManager, messages, persistenceAapter, publishMessageCount, subscription, template |
| Fields inherited from class junit.framework.TestCase |
|
| Methods inherited from class org.activemq.test.MessageStoreTestSupport |
assertDeliveryList, assertMessagesEqual, asText, closeAndReopenContainer, createConsumerInfo, createMessage, createMessageContainerManager, createPersistenceAdapter, createSubscription, createTopicMessageContainer, doAcknowledgeMessage, doAddMessage, dumpMessageIdentities, getClientID, getConsumerName, getMessage, getSubject, setUp, tearDown, testRecovery, testRecoveryOfNewConsumerWhichHasYetToAck, toStringFromSequenceNumber |
| 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 |
QueueMessageStoreTestSupport
public QueueMessageStoreTestSupport()
acknowledgeMessage
protected void acknowledgeMessage(int i)
throws javax.jms.JMSException
- Specified by:
acknowledgeMessage in class MessageStoreTestSupport
getQueueMessageContainer
protected org.activemq.service.QueueMessageContainer getQueueMessageContainer()
createDestination
protected org.activemq.message.ActiveMQDestination createDestination()
- Specified by:
createDestination in class MessageStoreTestSupport
recover
protected void recover()
throws javax.jms.JMSException
- Overrides:
recover in class MessageStoreTestSupport
createMessageAck
protected org.activemq.message.MessageAck createMessageAck(org.activemq.service.MessageIdentity messageIdentity,
javax.jms.Destination destination)
getMessagesToDispatch
protected org.activemq.message.ActiveMQMessage[] getMessagesToDispatch()
throws javax.jms.JMSException
- Specified by:
getMessagesToDispatch in class MessageStoreTestSupport