org.mule.util.queue
Class AbstractTransactionQueueManagerTestCase

java.lang.Object
  org.mule.tck.junit4.AbstractMuleTestCase
      org.mule.tck.junit4.AbstractMuleContextTestCase
          org.mule.util.queue.AbstractTransactionQueueManagerTestCase

Direct Known Subclasses:

FilePersistenceTestCase, NoPersistenceTestCase

public abstract class AbstractTransactionQueueManagerTestCase
extends AbstractMuleContextTestCase

Field Summary

protected Log

logger logger used by this class

Fields inherited from class org.mule.tck.junit4.AbstractMuleContextTestCase

callbackCalled, CLASSNAME_ANNOTATIONS_CONFIG_BUILDER, IGNORED_DOT_MULE_DIRS, LOCK_TIMEOUT, muleContext, RECEIVE_TIMEOUT, TEST_MESSAGE

Fields inherited from class org.mule.tck.junit4.AbstractMuleTestCase

DEFAULT_TEST_TIMEOUT_SECS, globalTimeout, name, TEST_TIMEOUT_SYSTEM_PROPERTY

Constructor Summary

AbstractTransactionQueueManagerTestCase()

Method Summary

protected abstract TransactionalQueueManager	createQueueManager()
protected abstract boolean	isPersistent()
protected void	purgeQueue(Queue queue)
void	testBench()
void	testOffer()
void	testPeek()
void	testPoll()
void	testPutTake_RespectsOrderOnPersistence()
void	testPutTake()
void	testPutTakeUntake()
void	testPutTakeUntakeRollbackUntake()
void	testPutWithPersistence()
void	testRecoverColdRestart()
void	testRecoverWarmRestart()
void	testTakePut()
void	testTakePutOverCapacity()
void	testTakePutRollbackPut()
void	testTransactedPutCommitWithPersistence()
void	testTransactedPutRollbackWithPersistence()
void	testTransactionsOnMultipleQueues()

Methods inherited from class org.mule.tck.junit4.AbstractMuleContextTestCase

addBuilders, configureMuleContext, createMuleContext, createObject, createObject, disposeContext, disposeContextPerTest, doSetUp, doTearDown, getBuilder, getConfigurationResources, getSensingNullMessageProcessor, getStartUpProperties, getTestConnector, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEventContext, getTestEventContext, getTestEventUsingFlow, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestService, getTestService, getTestService, getTestSession, getTestTransactedInboundEndpoint, getTestTransformer, getTriggerableMessageSource, getTriggerableMessageSource, initialiseObject, isDisposeContextPerClass, isGracefulShutdown, isStartContext, setDisposeContextPerClass, setStartContext, setUpMuleContext

Methods inherited from class org.mule.tck.junit4.AbstractMuleTestCase

clearExcludedFlag, clearRequestContext, createTestTimeoutRule, getTestHeader, getTestTimeoutSecs, getTimeoutSystemProperty, initializeMuleTest, isDisabledInThisEnvironment, isDisabledInThisEnvironment, isExcluded, isFailOnTimeout, isOffline, isTestIncludedInExclusionFile

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

protected transient Log logger

logger used by this class

Constructor Detail

AbstractTransactionQueueManagerTestCase

public AbstractTransactionQueueManagerTestCase()

Method Detail

createQueueManager

protected abstract TransactionalQueueManager createQueueManager()
                                                         throws Exception

Throws:

Exception

isPersistent

protected abstract boolean isPersistent()

testPutTake

public void testPutTake()
                 throws Exception

Throws:

Exception

testTakePut

public void testTakePut()
                 throws Exception

Throws:

Exception

testPutTakeUntake

public void testPutTakeUntake()
                       throws Exception

Throws:

Exception

testTakePutRollbackPut

public void testTakePutRollbackPut()
                            throws Exception

Throws:

Exception

testPutTakeUntakeRollbackUntake

public void testPutTakeUntakeRollbackUntake()
                                     throws Exception

Throws:

Exception

testTakePutOverCapacity

public void testTakePutOverCapacity()
                             throws Exception

Throws:

Exception

testPutWithPersistence

public void testPutWithPersistence()
                            throws Exception

Throws:

Exception

testTransactedPutCommitWithPersistence

public void testTransactedPutCommitWithPersistence()
                                            throws Exception

Throws:

Exception

testTransactedPutRollbackWithPersistence

public void testTransactedPutRollbackWithPersistence()
                                              throws Exception

Throws:

Exception

testPutTake_RespectsOrderOnPersistence

public void testPutTake_RespectsOrderOnPersistence()
                                            throws Exception

Throws:

Exception

testTransactionsOnMultipleQueues

public void testTransactionsOnMultipleQueues()
                                      throws Exception

Throws:

Exception

testPoll

public void testPoll()
              throws Exception

Throws:

Exception

testPeek

public void testPeek()
              throws Exception

Throws:

Exception

testOffer

public void testOffer()
               throws Exception

Throws:

Exception

testBench

public void testBench()
               throws Exception

Throws:

Exception

purgeQueue

protected void purgeQueue(Queue queue)
                   throws InterruptedException

Throws:

InterruptedException

testRecoverWarmRestart

public void testRecoverWarmRestart()
                            throws Exception

Throws:

Exception

testRecoverColdRestart

public void testRecoverColdRestart()
                            throws Exception

Throws:

Exception