org.apache.qpid.test.unit.close
Class CloseBeforeAckTest

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.close.CloseBeforeAckTest
All Implemented Interfaces:
junit.framework.Test

public class CloseBeforeAckTest
extends QpidBrokerTestCase

This test forces the situation where a session is closed whilst a message consumer is still in its onMessage method. Running in AUTO_ACK mode, the close call ought to wait until the onMessage method completes, and the ack is sent before closing the connection.

CRC Card
Responsibilities Collaborations
Check that closing a connection whilst handling a message, blocks till completion of the handler.


Nested Class Summary
(package private)  class CloseBeforeAckTest.TestThread1
           
 
Nested classes/interfaces inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase
QpidBrokerTestCase.MessageType
 
Field Summary
(package private)  Connection connection
           
(package private)  Session session
           
static String TEST_QUEUE_NAME
           
(package private)  CloseBeforeAckTest.TestThread1 testThread1
           
(package private)  org.apache.qpid.junit.concurrency.TestRunnable testThread2
           
 
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
CloseBeforeAckTest()
           
 
Method Summary
 void closeBeforeAutoAckManyTimes()
           
protected  void setUp()
           
protected  void tearDown()
           
 void testCloseBeforeAutoAck_QPID_397()
           
 
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
 

Field Detail

connection

Connection connection

session

Session session

TEST_QUEUE_NAME

public static final String TEST_QUEUE_NAME
See Also:
Constant Field Values

testThread1

CloseBeforeAckTest.TestThread1 testThread1

testThread2

org.apache.qpid.junit.concurrency.TestRunnable testThread2
Constructor Detail

CloseBeforeAckTest

public CloseBeforeAckTest()
Method Detail

testCloseBeforeAutoAck_QPID_397

public void testCloseBeforeAutoAck_QPID_397()
                                     throws Exception
Throws:
Exception

closeBeforeAutoAckManyTimes

public void closeBeforeAutoAckManyTimes()
                                 throws Exception
Throws:
Exception

setUp

protected void setUp()
              throws Exception
Overrides:
setUp in class QpidBrokerTestCase
Throws:
Exception

tearDown

protected void tearDown()
                 throws Exception
Overrides:
tearDown in class QpidBrokerTestCase
Throws:
Exception


Licensed to the Apache Software Foundation