|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjunit.framework.Assert
junit.framework.TestCase
org.apache.qpid.test.utils.QpidTestCase
org.apache.qpid.test.utils.QpidBrokerTestCase
org.apache.qpid.test.utils.FailoverBaseCase
org.apache.qpid.test.unit.ack.RecoverTest
public class RecoverTest
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase |
---|
QpidBrokerTestCase.MessageType |
Field Summary | |
---|---|
protected org.apache.qpid.client.AMQConnection |
_connection
|
protected MessageConsumer |
_consumer
|
protected org.apache.qpid.jms.Session |
_consumerSession
|
(package private) static org.slf4j.Logger |
_logger
|
(package private) static int |
SENT_COUNT
|
Fields inherited from class org.apache.qpid.test.utils.FailoverBaseCase |
---|
DEFAULT_FAILOVER_TIME, FAILING_PORT, FAILING_VM_PORT, failingPort |
Fields inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase |
---|
_broker, _brokerLanguage, _brokerLogPrefix, _brokerOutputStream, _brokerPersistent, _brokers, _configFile, _connectionFactory, _connections, _initialContext, _interleaveBrokerLog, _output, _outputFile, _testName, BROKER_READY, CONTENT, CPP, DEFAULT_MANAGEMENT_PORT, DEFAULT_MESSAGE_SIZE, DEFAULT_PORT, DEFAULT_SSL_PORT, DEFAULT_VM_PORT, EXTERNAL, INDEX, JAVA, LOGMONITOR_TIMEOUT, QPID_HOME, QpidHome, QUEUE, RECEIVE_TIMEOUT, TOPIC, VM |
Fields inherited from class org.apache.qpid.test.utils.QpidTestCase |
---|
MEMORY_STORE_CLASS_NAME, MS_CLASS_NAME_KEY |
Constructor Summary | |
---|---|
RecoverTest()
|
Method Summary | |
---|---|
protected void |
initTest()
|
protected void |
setUp()
|
void |
testAcknowledgePerConsumer()
|
void |
testOderingWithAsyncConsumer()
Goal : Same as testOderingWithSyncConsumer Test strategy : Same as testOderingWithSyncConsumer but using a Message Listener instead of a sync receive(). |
void |
testOderingWithSyncConsumer()
Goal : Check if ordering is preserved when doing recovery under reasonable circumstances. |
void |
testRecoverInAutoAckListener()
|
void |
testRecoverResendsMsgs()
|
void |
testRecoverResendsMsgsAckOnEarlier()
|
protected Message |
validateNextMessages(int nextCount,
int startIndex)
|
protected void |
validateRemainingMessages(int remaining)
|
Methods inherited from class org.apache.qpid.test.utils.FailoverBaseCase |
---|
failBroker, getConnectionFactory, getFailingPort, tearDown |
Methods inherited from class org.apache.qpid.test.utils.QpidTestCase |
---|
getTestProfileMessageStoreClassName, run |
Methods inherited from class junit.framework.TestCase |
---|
countTestCases, createResult, getName, run, 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, failNotEquals, failNotSame, failSame |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
static final org.slf4j.Logger _logger
protected org.apache.qpid.client.AMQConnection _connection
protected org.apache.qpid.jms.Session _consumerSession
protected MessageConsumer _consumer
static final int SENT_COUNT
Constructor Detail |
---|
public RecoverTest()
Method Detail |
---|
protected void setUp() throws Exception
setUp
in class FailoverBaseCase
Exception
protected void initTest() throws Exception
Exception
protected Message validateNextMessages(int nextCount, int startIndex) throws JMSException
JMSException
protected void validateRemainingMessages(int remaining) throws JMSException
JMSException
public void testRecoverResendsMsgs() throws Exception
Exception
public void testRecoverResendsMsgsAckOnEarlier() throws Exception
Exception
public void testAcknowledgePerConsumer() throws Exception
Exception
public void testRecoverInAutoAckListener() throws Exception
Exception
public void testOderingWithSyncConsumer() throws Exception
Exception
public void testOderingWithAsyncConsumer() throws Exception
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |