|
||||||||||
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.unit.xa.AbstractXATestCase
org.apache.qpid.test.unit.xa.TopicTest
public class TopicTest
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase |
---|
QpidBrokerTestCase.MessageType |
Field Summary |
---|
Fields inherited from class org.apache.qpid.test.unit.xa.AbstractXATestCase |
---|
_consumer, _message, _producer, _sequenceNumberPropertyName, _xaResource |
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 | |
---|---|
TopicTest()
|
Method Summary | |
---|---|
static void |
failure()
|
static boolean |
getFailureStatus()
|
static junit.framework.TestSuite |
getSuite()
Gets the test suite tests |
void |
init()
Initialize standard actors |
static void |
main(String[] args)
Run the test suite. |
static void |
reset()
|
void |
tearDown()
|
void |
testDurSub()
strategy: Produce a message within Tx1 and commit tx1. |
void |
testDurSubCrash()
strategy: Produce a message within Tx1 and commit tx1. |
void |
testMigrateDurableSubscriber()
strategy: create a standard durable subscriber produce 3 messages consume the first message with that durable subscriber close the standard session that deactivates the durable subscriber migrate the durable subscriber to an xa one consume the second message with that xa durable subscriber close the xa session that deactivates the durable subscriber reconnect to the durable subscriber with a standard session consume the two remaining messages and check that the topic is empty! |
void |
testMultiMessagesDurSub()
strategy: create a XA durable subscriber dusSub, produce 7 messages with the standard session, consume 2 messages respectively with tx1, tx2 and tx3 abort tx2, we now expect to receive messages 3 and 4 first! Receive 3 messages within tx1 i.e. |
void |
testMultiMessagesDurSubCrash()
strategy: create a XA durable subscriber dusSub, produce 10 messages with the standard session, consume 2 messages respectively with tx1, tx2 and tx3 prepare xid2 and xid3 crash the server Redo the job for xid1 that has been aborted by server crash abort tx2, we now expect to receive messages 3 and 4 first! Receive 3 messages within tx1 i.e. |
void |
testProducer()
Uses two transactions respectively with xid1 and xid2 that are use to send a message within xid1 and xid2. |
void |
testRecover()
strategy: Produce a message within Tx1 and prepare tx1. |
Methods inherited from class org.apache.qpid.test.unit.xa.AbstractXATestCase |
---|
getNewXid, init, setUp |
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 |
Constructor Detail |
---|
public TopicTest()
Method Detail |
---|
public static junit.framework.TestSuite getSuite()
public static void main(String[] args)
args
- Any command line arguments specified to this class.public void tearDown() throws Exception
tearDown
in class QpidBrokerTestCase
Exception
public void init()
init
in class AbstractXATestCase
public void testProducer()
public void testDurSub()
public void testMultiMessagesDurSub()
public void testMultiMessagesDurSubCrash()
public void testDurSubCrash()
public void testRecover()
public void testMigrateDurableSubscriber()
public static void failure()
public static void reset()
public static boolean getFailureStatus()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |