org.apache.qpid.systest
Class GlobalQueuesTest

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.GlobalQueuesTest
All Implemented Interfaces:
ExceptionListener, junit.framework.Test, org.apache.qpid.jms.ConnectionListener
Direct Known Subclasses:
GlobalTopicsTest, TopicTest

public class GlobalQueuesTest
extends TestingBaseCase

QPID-1447 : Add slow consumer detection and disconnection. Slow consumers should on a topic should expect to receive a 506 : Resource Error if the hit a predefined threshold.


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
GlobalQueuesTest()
           
 
Method Summary
 void setConfig(String property, String value, boolean deleteDurable)
          VirtualHost Plugin Configuration 1 MINUTES
 void testTopicConsumerMessageAge()
          Test that setting messageAge has an effect on topics Sets the messageAge to be half the disconnection wait timeout Send 10 messages and then ensure that we get disconnected as we will wait for the full timeout.
 void testTopicConsumerMessageCount()
          Test that setting messageCount takes affect on topics We send 10 messages and disconnect at 9
 void testTopicConsumerMessageSize()
          Test that setting depth has an effect on topics Sets the message size for the test Sets the depth to be 9 * the depth Ensure that sending 10 messages causes the disconnection
 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

GlobalQueuesTest

public GlobalQueuesTest()
Method Detail

setConfig

public void setConfig(String property,
                      String value,
                      boolean deleteDurable)
               throws NamingException,
                      IOException,
                      ConfigurationException
VirtualHost Plugin Configuration 1 MINUTES

Throws:
NamingException
IOException
ConfigurationException

testTopicConsumerMessageCount

public void testTopicConsumerMessageCount()
                                   throws Exception
Test that setting messageCount takes affect on topics We send 10 messages and disconnect at 9

Throws:
Exception

testTopicConsumerMessageSize

public void testTopicConsumerMessageSize()
                                  throws Exception
Test that setting depth has an effect on topics 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

testTopicConsumerMessageAge

public void testTopicConsumerMessageAge()
                                 throws Exception
Test that setting messageAge has an effect on topics Sets the messageAge to be half the disconnection wait timeout Send 10 messages and then ensure that we get disconnected as we will wait for the full timeout.

Throws:
Exception

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