public class LocalTxQueueTransactionRecovererTestCase extends AbstractMuleContextTestCase
Modifier and Type | Field and Description |
---|---|
static String |
MESSAGE_CONTENT |
static String |
QUEUE_NAME |
org.junit.rules.TemporaryFolder |
temporaryFolder |
callbackCalled, CLASSNAME_ANNOTATIONS_CONFIG_BUILDER, IGNORED_DOT_MULE_DIRS, LOCK_TIMEOUT, muleContext, RECEIVE_TIMEOUT, TEST_MESSAGE, TEST_PAYLOAD, WORKING_DIRECTORY_SYSTEM_PROPERTY_KEY, workingDirectory
DEFAULT_TEST_TIMEOUT_SECS, globalTimeout, logger, name, TEST_TIMEOUT_SYSTEM_PROPERTY, TESTING_MODE_PROPERTY_NAME
Constructor and Description |
---|
LocalTxQueueTransactionRecovererTestCase() |
Modifier and Type | Method and Description |
---|---|
protected void |
configureMuleContext(MuleContextBuilder contextBuilder)
Override this method to set properties of the MuleContextBuilder before it is
used to create the MuleContext.
|
protected void |
doSetUp()
Enables the adding of extra behavior on the set up stage of a test right
after the creation of the mule context in
AbstractMuleContextTestCase.setUpMuleContext() . |
void |
failBetweenLogEntryWriteAndRealPoolThenRecover() |
void |
offerAndFailBetweenRealOfferAndCommitThenRecover() |
void |
offerAndFailThenRecover() |
void |
pollAndFailThenRecover() |
void |
pollAndFailThenRecoverWithTwoElements() |
addBuilders, createMuleContext, createObject, createObject, disposeContext, disposeContextPerTest, doSetUpBeforeMuleContextCreation, doTearDown, doTearDownAfterMuleContextDispose, getBuilder, getConfigurationResources, getFileInsideWorkingDirectory, getSensingNullMessageProcessor, getStartUpProperties, getTestConnector, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEventContext, getTestEventContext, getTestEventUsingFlow, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestMuleMessage, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestService, getTestService, getTestService, getTestSession, getTestTransactedInboundEndpoint, getTestTransformer, getTriggerableMessageSource, getTriggerableMessageSource, getWorkingDirectory, initialiseObject, isDisposeContextPerClass, isGracefulShutdown, isStartContext, setDisposeContextPerClass, setStartContext, setUpMuleContext
clearExcludedFlag, clearRequestContext, clearTestCaseName, createTestTimeoutRule, dumpFilteredThreadsInTest, getTestHeader, getTestTimeoutSecs, getTimeoutSystemProperty, initializeMuleTest, isDisabledInThisEnvironment, isDisabledInThisEnvironment, isExcluded, isFailOnTimeout, isOffline, isTestIncludedInExclusionFile, takeTestCaseName
public static final String QUEUE_NAME
public static final String MESSAGE_CONTENT
public org.junit.rules.TemporaryFolder temporaryFolder
public LocalTxQueueTransactionRecovererTestCase()
protected void doSetUp() throws Exception
AbstractMuleContextTestCase
AbstractMuleContextTestCase.setUpMuleContext()
.
Under normal circumstances this method could be replaced by a
@Before
annotated method.
doSetUp
in class AbstractMuleContextTestCase
Exception
- if something fails that should halt the test caseprotected void configureMuleContext(MuleContextBuilder contextBuilder)
AbstractMuleContextTestCase
configureMuleContext
in class AbstractMuleContextTestCase
public void pollAndFailThenRecoverWithTwoElements() throws Exception
Exception
public void failBetweenLogEntryWriteAndRealPoolThenRecover() throws Exception
Exception
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.