org.apache.qpid.test.unit.ct
Class DurableSubscriberTest

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.unit.ct.DurableSubscriberTest
All Implemented Interfaces:
junit.framework.Test

public class DurableSubscriberTest
extends QpidBrokerTestCase

Crash Recovery tests for durable subscription


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.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
DurableSubscriberTest()
           
 
Method Summary
 void testDurSubChangedToHaveSelectorThenRestart()
          create and register a durable subscriber without a message selector and then unsubscribe it create and register a durable subscriber with a message selector and then close it restart the broker send matching and non matching messages recreate and register the durable subscriber with a message selector verify only the matching messages are received
 void testDurSubChangedToNotHaveSelectorThenRestart()
          create and register a durable subscriber with a message selector and then unsubscribe it create and register a durable subscriber without a message selector and then close it restart the broker send matching and non matching messages recreate and register the durable subscriber without a message selector verify ALL the sent messages are received
 void testDurSubRestoredAfterNonPersistentMessageSent()
          test strategy: create and register a durable subscriber then close it create a publisher and send a persistant message followed by a non persistant message crash and restart the broker recreate the durable subscriber and check that only the first message is received
 void testDurSubRestoresMessageSelector()
          create and register a durable subscriber with a message selector and then close it crash the broker create a publisher and send 5 right messages and 5 wrong messages recreate the durable subscriber and check we receive the 5 expected messages
 void testResubscribeWithChangedSelectorAndRestart()
           
 
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, setUp, 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
 

Constructor Detail

DurableSubscriberTest

public DurableSubscriberTest()
Method Detail

testDurSubRestoredAfterNonPersistentMessageSent

public void testDurSubRestoredAfterNonPersistentMessageSent()
                                                     throws Exception
test strategy: create and register a durable subscriber then close it create a publisher and send a persistant message followed by a non persistant message crash and restart the broker recreate the durable subscriber and check that only the first message is received

Throws:
Exception

testDurSubRestoresMessageSelector

public void testDurSubRestoresMessageSelector()
                                       throws Exception
create and register a durable subscriber with a message selector and then close it crash the broker create a publisher and send 5 right messages and 5 wrong messages recreate the durable subscriber and check we receive the 5 expected messages

Throws:
Exception

testDurSubChangedToHaveSelectorThenRestart

public void testDurSubChangedToHaveSelectorThenRestart()
                                                throws Exception
create and register a durable subscriber without a message selector and then unsubscribe it create and register a durable subscriber with a message selector and then close it restart the broker send matching and non matching messages recreate and register the durable subscriber with a message selector verify only the matching messages are received

Throws:
Exception

testDurSubChangedToNotHaveSelectorThenRestart

public void testDurSubChangedToNotHaveSelectorThenRestart()
                                                   throws Exception
create and register a durable subscriber with a message selector and then unsubscribe it create and register a durable subscriber without a message selector and then close it restart the broker send matching and non matching messages recreate and register the durable subscriber without a message selector verify ALL the sent messages are received

Throws:
Exception

testResubscribeWithChangedSelectorAndRestart

public void testResubscribeWithChangedSelectorAndRestart()
                                                  throws Exception
Throws:
Exception


Licensed to the Apache Software Foundation