|
||||||||||
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.client.failover.FailoverTest
public class FailoverTest
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase |
---|
QpidBrokerTestCase.MessageType |
Field Summary | |
---|---|
protected Connection |
connection
|
protected int |
numMessages
|
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, RECEIVE_TIMEOUT, TOPIC, VM |
Fields inherited from class org.apache.qpid.test.utils.QpidTestCase |
---|
MEMORY_STORE_CLASS_NAME, MS_CLASS_NAME_KEY |
Constructor Summary | |
---|---|
FailoverTest()
|
Method Summary | |
---|---|
void |
bytesReceived(long count)
|
void |
bytesSent(long count)
|
void |
failoverComplete()
|
protected void |
init(boolean transacted,
int mode)
|
boolean |
preFailover(boolean redirect)
|
boolean |
preResubscribe()
|
protected void |
runP2PFailover(int totalMessages,
boolean consumeAll,
boolean produceAll,
boolean transacted)
|
protected void |
setUp()
|
void |
tearDown()
|
void |
test4MinuteFailover()
The client used to have a fixed timeout of 4 minutes after which failover would no longer work. |
void |
testClientAckFailover()
|
void |
testFailoverInALoop()
The idea is to run a failover test in a loop by failing over to the other broker each time. |
void |
testP2PFailover()
|
void |
testP2PFailoverTransacted()
|
void |
testP2PFailoverTransactedWithMessagesLeftToConsumeAndProduce()
|
void |
testP2PFailoverWithMessagesLeftToConsume()
|
void |
testP2PFailoverWithMessagesLeftToConsumeAndProduce()
|
Methods inherited from class org.apache.qpid.test.utils.FailoverBaseCase |
---|
failBroker, getConnectionFactory, getFailingPort |
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 |
---|
protected int numMessages
protected Connection connection
Constructor Detail |
---|
public FailoverTest()
Method Detail |
---|
protected void setUp() throws Exception
setUp
in class FailoverBaseCase
Exception
protected void init(boolean transacted, int mode) throws JMSException, NamingException
JMSException
NamingException
public void tearDown() throws Exception
tearDown
in class FailoverBaseCase
Exception
public void testP2PFailover() throws Exception
Exception
public void testP2PFailoverWithMessagesLeftToConsumeAndProduce() throws Exception
Exception
public void testP2PFailoverWithMessagesLeftToConsume() throws Exception
Exception
public void testP2PFailoverTransacted() throws Exception
Exception
public void testP2PFailoverTransactedWithMessagesLeftToConsumeAndProduce() throws Exception
Exception
protected void runP2PFailover(int totalMessages, boolean consumeAll, boolean produceAll, boolean transacted) throws JMSException, NamingException
JMSException
NamingException
public void testClientAckFailover() throws Exception
Exception
public void test4MinuteFailover() throws Exception
Exception
- if something unexpected occurs in the test.public void testFailoverInALoop() throws Exception
Exception
public void bytesSent(long count)
bytesSent
in interface org.apache.qpid.jms.ConnectionListener
public void bytesReceived(long count)
bytesReceived
in interface org.apache.qpid.jms.ConnectionListener
public boolean preFailover(boolean redirect)
preFailover
in interface org.apache.qpid.jms.ConnectionListener
public boolean preResubscribe()
preResubscribe
in interface org.apache.qpid.jms.ConnectionListener
public void failoverComplete()
failoverComplete
in interface org.apache.qpid.jms.ConnectionListener
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |