org.apache.qpid.test.utils
Class FailoverBaseCase

java.lang.Object
  extended by junit.framework.Assert
      extended by junit.framework.TestCase
          extended by org.apache.qpid.test.utils.QpidTestCase
              extended by org.apache.qpid.test.utils.QpidBrokerTestCase
                  extended by org.apache.qpid.test.utils.FailoverBaseCase
All Implemented Interfaces:
junit.framework.Test
Direct Known Subclasses:
Acknowledge2ConsumersTest, AcknowledgeTest, DirtyTransactedPublishTest, FailoverTest, MessageDisappearWithIOExceptionTest, QueueBrowserAutoAckTest, RecoverTest

public class FailoverBaseCase
extends QpidBrokerTestCase


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase
QpidBrokerTestCase.MessageType
 
Field Summary
protected static org.slf4j.Logger _logger
           
static long DEFAULT_FAILOVER_TIME
           
static int FAILING_PORT
           
static int FAILING_VM_PORT
           
protected  int 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
FailoverBaseCase()
           
 
Method Summary
 void failBroker(int port)
           
 org.apache.qpid.client.AMQConnectionFactory getConnectionFactory()
          We are using failover factories
protected  int getFailingPort()
           
protected  void setUp()
           
 void tearDown()
           
 
Methods inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase
cleanBroker, createMessage, createNextMessage, drainQueue, getBroker, getBrokerCommand, getClientConnection, getConfigurationStringProperty, getConnection, getConnection, getConnection, getConnectionFactory, getConnectionURL, getInitialContext, getLogger, getManagementPort, getMessageSize, getPort, getPort, getTestConfigFile, getTestQueue, getTestQueueName, getTestVirtualhostsFile, isBroker010, isBroker08, isBrokerStorePersistent, isCppBroker, isExternalBroker, isJavaBroker, makeVirtualHostPersistent, reloadBrokerSecurityConfig, restartBroker, restartBroker, revertLoggingLevels, revertSystemProperties, runBare, saveTestConfiguration, saveTestVirtualhosts, sendMessage, sendMessage, sendMessage, setBrokerEnvironment, setBrokerOnlySystemProperty, setConfigurationProperty, setLoggerLevel, setMessageSize, setSystemProperty, setSystemProperty, setTestClientSystemProperty, startBroker, startBroker, stopBroker, stopBroker
 
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

_logger

protected static final org.slf4j.Logger _logger

FAILING_VM_PORT

public static int FAILING_VM_PORT

FAILING_PORT

public static int FAILING_PORT

DEFAULT_FAILOVER_TIME

public static final long DEFAULT_FAILOVER_TIME
See Also:
Constant Field Values

failingPort

protected int failingPort
Constructor Detail

FailoverBaseCase

public FailoverBaseCase()
Method Detail

getFailingPort

protected int getFailingPort()

setUp

protected void setUp()
              throws Exception
Overrides:
setUp in class QpidBrokerTestCase
Throws:
Exception

getConnectionFactory

public org.apache.qpid.client.AMQConnectionFactory getConnectionFactory()
                                                                 throws NamingException
We are using failover factories

Overrides:
getConnectionFactory in class QpidBrokerTestCase
Returns:
a connection
Throws:
Exception
NamingException

tearDown

public void tearDown()
              throws Exception
Overrides:
tearDown in class QpidBrokerTestCase
Throws:
Exception

failBroker

public void failBroker(int port)


Licensed to the Apache Software Foundation