org.apache.qpid.server.queue
Class ProducerFlowControlTest

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.logging.AbstractTestLogging
                      extended by org.apache.qpid.server.queue.ProducerFlowControlTest
All Implemented Interfaces:
junit.framework.Test

public class ProducerFlowControlTest
extends AbstractTestLogging


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.server.logging.AbstractTestLogging
_monitor, DEFAULT_LOG_WAIT, TEST_LOG_PREFIX
 
Fields inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase
_broker, _brokerLanguage, _brokerLogPrefix, _brokerOutputStream, _brokerPersistent, _brokers, _configFile, _connectionFactory, _connections, _initialContext, _interleaveBrokerLog, _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
ProducerFlowControlTest()
           
 
Method Summary
 void setUp()
           
 void tearDown()
           
 void testBrokerLogMessages()
           
 void testCapacityExceededCausesBlock()
           
 void testClientLogMessages()
           
 void testFlowControlAttributeModificationViaJMX()
           
 void testFlowControlOnCapacityResumeEqual()
           
 void testFlowControlSoak()
           
 void testSendTimeout()
           
 
Methods inherited from class org.apache.qpid.server.logging.AbstractTestLogging
assertLoggingNotYetOccured, dumpLogs, dumpLogs, filterResultsByVirtualHost, findMatches, fromActor, fromMessage, fromSubject, getChannelID, getConnectionID, getLog, getLogMessage, getLogMessageFromEnd, getMessageID, getMessageString, setLogMessagePrefix, splitResultsOnConnectionID, validateMessageID, waitAndFindMatches, waitAndFindMatches, waitForMessage, waitForMessage
 
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
 
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

ProducerFlowControlTest

public ProducerFlowControlTest()
Method Detail

setUp

public void setUp()
           throws Exception
Overrides:
setUp in class AbstractTestLogging
Throws:
Exception

tearDown

public void tearDown()
              throws Exception
Overrides:
tearDown in class AbstractTestLogging
Throws:
Exception

testCapacityExceededCausesBlock

public void testCapacityExceededCausesBlock()
                                     throws JMSException,
                                            NamingException,
                                            org.apache.qpid.AMQException,
                                            InterruptedException
Throws:
JMSException
NamingException
org.apache.qpid.AMQException
InterruptedException

testBrokerLogMessages

public void testBrokerLogMessages()
                           throws JMSException,
                                  NamingException,
                                  org.apache.qpid.AMQException,
                                  InterruptedException,
                                  IOException
Throws:
JMSException
NamingException
org.apache.qpid.AMQException
InterruptedException
IOException

testClientLogMessages

public void testClientLogMessages()
                           throws JMSException,
                                  NamingException,
                                  org.apache.qpid.AMQException,
                                  InterruptedException,
                                  IOException
Throws:
JMSException
NamingException
org.apache.qpid.AMQException
InterruptedException
IOException

testFlowControlOnCapacityResumeEqual

public void testFlowControlOnCapacityResumeEqual()
                                          throws JMSException,
                                                 NamingException,
                                                 org.apache.qpid.AMQException,
                                                 InterruptedException
Throws:
JMSException
NamingException
org.apache.qpid.AMQException
InterruptedException

testFlowControlSoak

public void testFlowControlSoak()
                         throws Exception,
                                NamingException,
                                org.apache.qpid.AMQException,
                                InterruptedException
Throws:
Exception
NamingException
org.apache.qpid.AMQException
InterruptedException

testSendTimeout

public void testSendTimeout()
                     throws JMSException,
                            NamingException,
                            org.apache.qpid.AMQException,
                            InterruptedException
Throws:
JMSException
NamingException
org.apache.qpid.AMQException
InterruptedException

testFlowControlAttributeModificationViaJMX

public void testFlowControlAttributeModificationViaJMX()
                                                throws JMSException,
                                                       NamingException,
                                                       org.apache.qpid.AMQException,
                                                       InterruptedException,
                                                       Exception
Throws:
JMSException
NamingException
org.apache.qpid.AMQException
InterruptedException
Exception


Licensed to the Apache Software Foundation