org.apache.qpid.systest
Class SubscriptionTest

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.systest.TestingBaseCase
                      extended by org.apache.qpid.systest.SubscriptionTest
All Implemented Interfaces:
ExceptionListener, junit.framework.Test, org.apache.qpid.jms.ConnectionListener

public class SubscriptionTest
extends TestingBaseCase

Test SCD when configured with Subscription details. We run the subscription based tests here to validate that the subscriptionname value is correctly associated with the subscription.


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase
QpidBrokerTestCase.MessageType
 
Field Summary
protected  String CONFIG_SECTION
           
 
Fields inherited from class org.apache.qpid.systest.TestingBaseCase
_connectionException, _destination, _disconnectionLatch, _publisherError, DISCONNECTION_WAIT, MAX_QUEUE_MESSAGE_COUNT, MESSAGE_SIZE
 
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
SubscriptionTest()
           
 
Method Summary
 void setConfig(String property, String value, boolean deleteDurable)
          Add configuration for the queue that relates just to this test.
 void testTopicDurableConsumerMessageAge()
          Test that setting messageAge has an effect on topics Ensure we set the delete-persistent option Sets the messageAge to be 1/5 the disconnection wait timeout (or 1sec) Send 10 messages and then ensure that we get disconnected as we will wait for the full timeout.
 void testTopicDurableConsumerMessageCount()
          Test that setting messageCount takes affect on a durable Consumer Ensure we set the delete-persistent option We send 10 messages and disconnect at 9
 void testTopicDurableConsumerMessageSize()
          Test that setting depth has an effect on durable consumer topics Ensure we set the delete-persistent option Sets the message size for the test Sets the depth to be 9 * the depth Ensure that sending 10 messages causes the disconnection
 
Methods inherited from class org.apache.qpid.systest.TestingBaseCase
bytesReceived, bytesSent, failoverComplete, onException, preFailover, preResubscribe, setProperty, setUp, topicConsumer
 
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

CONFIG_SECTION

protected String CONFIG_SECTION
Constructor Detail

SubscriptionTest

public SubscriptionTest()
Method Detail

setConfig

public void setConfig(String property,
                      String value,
                      boolean deleteDurable)
               throws NamingException,
                      IOException,
                      ConfigurationException
Add configuration for the queue that relates just to this test. We use the getTestQueueName() as our subscription. To ensure the config sections do not overlap we identify each section with a _count value. This would allow each test to configure more than one section.

Parameters:
property - to set
value - the value to set
deleteDurable - should deleteDurable be set.
Throws:
NamingException
IOException
ConfigurationException

testTopicDurableConsumerMessageCount

public void testTopicDurableConsumerMessageCount()
                                          throws Exception
Test that setting messageCount takes affect on a durable Consumer Ensure we set the delete-persistent option We send 10 messages and disconnect at 9

Throws:
Exception

testTopicDurableConsumerMessageSize

public void testTopicDurableConsumerMessageSize()
                                         throws Exception
Test that setting depth has an effect on durable consumer topics Ensure we set the delete-persistent option Sets the message size for the test Sets the depth to be 9 * the depth Ensure that sending 10 messages causes the disconnection

Throws:
Exception

testTopicDurableConsumerMessageAge

public void testTopicDurableConsumerMessageAge()
                                        throws Exception
Test that setting messageAge has an effect on topics Ensure we set the delete-persistent option Sets the messageAge to be 1/5 the disconnection wait timeout (or 1sec) Send 10 messages and then ensure that we get disconnected as we will wait for the full timeout.

Throws:
Exception


Licensed to the Apache Software Foundation