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

Fields

Modifier and Type	Field and Description
protected QueueTestComponent	disposeTest
protected Log	logger logger used by this class
static int	THREAD_EXECUTION_TIMEOUT

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, TEST_PAYLOAD, WORKING_DIRECTORY_SYSTEM_PROPERTY_KEY, workingDirectory

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

DEFAULT_TEST_TIMEOUT_SECS, globalTimeout, name, TEST_TIMEOUT_SYSTEM_PROPERTY, TESTING_MODE_PROPERTY_NAME

Constructor Summary

Constructors

Constructor and Description
AbstractTransactionQueueManagerTestCase()

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract AbstractQueueManager	createQueueManager()
protected abstract boolean	isPersistent()
void	testClearInTransaction()
void	testClearWithoutTransaction()
void	testDisposeQueueByNameInTransaction()
void	testDisposeQueueInTransaction()
void	testDisposeQueueWithoutTransaction()
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, doSetUpBeforeMuleContextCreation, doTearDown, doTearDownAfterMuleContextDispose, getBuilder, getConfigurationResources, getFileInsideWorkingDirectory, getNonBlockingResponse, getNonBlockingTestEventUsingFlow, getSensingNullMessageProcessor, getStartUpProperties, getTestConnector, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEventContext, getTestEventContext, getTestEventUsingFlow, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestMuleMessage, getTestMuleMessage, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestService, getTestService, getTestService, getTestSession, getTestTransactedInboundEndpoint, getTestTransformer, getTriggerableMessageSource, getTriggerableMessageSource, getWorkingDirectory, initialiseObject, isDisposeContextPerClass, isGracefulShutdown, isStartContext, setDisposeContextPerClass, setStartContext, setUpMuleContext

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

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

Methods inherited from class java.lang.Object

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

Field Detail

THREAD_EXECUTION_TIMEOUT

public static final int THREAD_EXECUTION_TIMEOUT

See Also:

Constant Field Values

logger

protected transient Log logger

logger used by this class

disposeTest

protected QueueTestComponent disposeTest

Constructor Detail

AbstractTransactionQueueManagerTestCase

public AbstractTransactionQueueManagerTestCase()

Method Detail

createQueueManager

protected abstract AbstractQueueManager 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

testClearWithoutTransaction

public void testClearWithoutTransaction()
                                 throws Exception

Throws:

Exception

testClearInTransaction

public void testClearInTransaction()
                            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

testRecoverWarmRestart

public void testRecoverWarmRestart()
                            throws Exception

Throws:

Exception

testRecoverColdRestart

public void testRecoverColdRestart()
                            throws Exception

Throws:

Exception

testDisposeQueueWithoutTransaction

public void testDisposeQueueWithoutTransaction()
                                        throws Exception

Throws:

Exception

testDisposeQueueInTransaction

public void testDisposeQueueInTransaction()
                                   throws Exception

Throws:

Exception

testDisposeQueueByNameInTransaction

public void testDisposeQueueByNameInTransaction()
                                         throws Exception

Throws:

Exception