|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjunit.framework.Assert
junit.framework.TestCase
org.apache.qpid.test.utils.QpidTestCase
org.apache.qpid.test.utils.QpidBrokerTestCase
org.apache.qpid.systest.TestingBaseCase
org.apache.qpid.systest.GlobalQueuesTest
public class GlobalQueuesTest
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 |
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.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 |
---|
protected String CONFIG_SECTION
Constructor Detail |
---|
public GlobalQueuesTest()
Method Detail |
---|
public void setConfig(String property, String value, boolean deleteDurable) throws NamingException, IOException, ConfigurationException
NamingException
IOException
ConfigurationException
public void testTopicConsumerMessageCount() throws Exception
Exception
public void testTopicConsumerMessageSize() throws Exception
Exception
public void testTopicConsumerMessageAge() throws Exception
Exception
public void testTopicDurableConsumerMessageCount() throws Exception
Exception
public void testTopicDurableConsumerMessageSize() throws Exception
Exception
public void testTopicDurableConsumerMessageAge() throws Exception
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |