org.apache.qpid.server.persistent
Class NoLocalAfterRecoveryTest

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.server.persistent.NoLocalAfterRecoveryTest
All Implemented Interfaces:
junit.framework.Test, org.apache.qpid.jms.ConnectionListener

public class NoLocalAfterRecoveryTest
extends QpidBrokerTestCase
implements org.apache.qpid.jms.ConnectionListener

QPID-1813 : We do not store the client id with a message so on store restart that information is lost and we are unable to perform no local checks. QPID-1813 highlights the lack of testing here as the broker will NPE as it assumes that the client id of the publisher will always exist


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase
QpidBrokerTestCase.MessageType
 
Field Summary
protected  org.apache.qpid.jms.ConnectionURL _connectionURL
           
protected  String MY_TOPIC_SUBSCRIPTION_NAME
           
protected static int SEND_COUNT
           
 
Fields inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase
_broker, _brokerLanguage, _brokerLogPrefix, _brokerOutputStream, _brokerPersistent, _brokers, _configFile, _connectionFactory, _connections, _initialContext, _interleaveBrokerLog, _logger, _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
NoLocalAfterRecoveryTest()
           
 
Method Summary
protected  List<Message> assertReceiveMessage(MessageConsumer messageConsumer, int count)
           
 void bytesReceived(long count)
           
 void bytesSent(long count)
           
 void failoverComplete()
           
 boolean preFailover(boolean redirect)
           
 boolean preResubscribe()
           
protected  List<Message> receiveMessage(MessageConsumer messageConsumer, int count)
           
protected  void setUp()
           
 void test()
           
 
Methods inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase
cleanBroker, createMessage, createNextMessage, drainQueue, getBroker, getBrokerCommand, getClientConnection, getConfigurationStringProperty, getConnection, getConnection, getConnection, getConnectionFactory, 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, 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

MY_TOPIC_SUBSCRIPTION_NAME

protected final String MY_TOPIC_SUBSCRIPTION_NAME

SEND_COUNT

protected static final int SEND_COUNT
See Also:
Constant Field Values

_connectionURL

protected org.apache.qpid.jms.ConnectionURL _connectionURL
Constructor Detail

NoLocalAfterRecoveryTest

public NoLocalAfterRecoveryTest()
Method Detail

setUp

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

test

public void test()
          throws Exception
Throws:
Exception

assertReceiveMessage

protected List<Message> assertReceiveMessage(MessageConsumer messageConsumer,
                                             int count)
                                      throws JMSException
Throws:
JMSException

receiveMessage

protected List<Message> receiveMessage(MessageConsumer messageConsumer,
                                       int count)
                                throws JMSException
Throws:
JMSException

bytesSent

public void bytesSent(long count)
Specified by:
bytesSent in interface org.apache.qpid.jms.ConnectionListener

bytesReceived

public void bytesReceived(long count)
Specified by:
bytesReceived in interface org.apache.qpid.jms.ConnectionListener

preFailover

public boolean preFailover(boolean redirect)
Specified by:
preFailover in interface org.apache.qpid.jms.ConnectionListener

preResubscribe

public boolean preResubscribe()
Specified by:
preResubscribe in interface org.apache.qpid.jms.ConnectionListener

failoverComplete

public void failoverComplete()
Specified by:
failoverComplete in interface org.apache.qpid.jms.ConnectionListener


Licensed to the Apache Software Foundation