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

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

public class MessageRequeueTest
extends QpidBrokerTestCase


Nested Class Summary
(package private)  class MessageRequeueTest.Consumer
           
 
Nested classes/interfaces inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase
QpidBrokerTestCase.MessageType
 
Field Summary
protected  String BROKER
           
(package private)  QpidClientConnection conn
           
protected static AtomicInteger consumerIds
           
protected  int consumeTimeout
           
protected  Integer numTestMessages
           
protected  String payload
           
protected  String queue
           
 
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
MessageRequeueTest()
           
 
Method Summary
protected  void setUp()
           
protected  void tearDown()
           
 void testDrain()
          multiple consumers
 void testRequeue()
           
 void testTwoCompetingConsumers()
          multiple consumers Based on code subbmitted by client FT-304
 
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

consumerIds

protected static AtomicInteger consumerIds

numTestMessages

protected final Integer numTestMessages

consumeTimeout

protected final int consumeTimeout
See Also:
Constant Field Values

queue

protected final String queue
See Also:
Constant Field Values

payload

protected String payload

BROKER

protected final String BROKER
See Also:
Constant Field Values

conn

QpidClientConnection conn
Constructor Detail

MessageRequeueTest

public MessageRequeueTest()
Method Detail

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

testDrain

public void testDrain()
               throws Exception
multiple consumers

Throws:
JMSException - if a JMS problem occurs
InterruptedException - on timeout
Exception

testTwoCompetingConsumers

public void testTwoCompetingConsumers()
multiple consumers Based on code subbmitted by client FT-304


testRequeue

public void testRequeue()
                 throws JMSException,
                        org.apache.qpid.AMQException,
                        org.apache.qpid.url.URLSyntaxException
Throws:
JMSException
org.apache.qpid.AMQException
org.apache.qpid.url.URLSyntaxException


Licensed to the Apache Software Foundation