public abstract class AbstractJmsRedeliveryTestCase extends AbstractServiceAndFlowTestCase
AbstractServiceAndFlowTestCase.ConfigVariant
Modifier and Type | Field and Description |
---|---|
protected CounterCallback |
callback |
protected MuleClient |
client |
protected static String |
JMS_DEAD_LETTER |
protected static String |
JMS_INPUT_QUEUE |
protected static String |
JMS_INPUT_QUEUE2 |
protected Latch |
messageRedeliveryExceptionFired |
protected int |
timeout |
configResources, variant
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 |
---|
AbstractJmsRedeliveryTestCase(AbstractServiceAndFlowTestCase.ConfigVariant variant,
String configResources) |
Modifier and Type | Method and Description |
---|---|
protected void |
assertMessageInDlq() |
protected void |
assertMessageInDlqRollbackEs() |
protected void |
assertNoMessageInDlq(String location) |
void |
cleanUpMaxRedelivery() |
protected abstract int |
getMaxRedelivery() |
protected abstract int |
getMaxRedeliveryAttempts() |
static Collection<Object[]> |
parameters() |
protected void |
purgeQueue() |
void |
setUp() |
protected void |
setupCallback() |
doSetUp, doSetUpForFlow, doSetUpForService, getConfigFile, getConfigFiles, getTestHeader
clearFlowAssertions, getBuilder, getComponent, getComponent, getConfigResources, getFlowConstruct, getFunctionalTestComponent, getSubFlow, loadResource, loadResourceAsString, lookupFlowConstruct, runFlow, runFlow, runFlow, runFlowAndExpect, runFlowAndExpectProperty, runFlowNonBlocking, runFlowNonBlocking, runFlowNonBlocking, runFlowWithPayloadAndExpect, runSchedulersOnce, stopFlowConstruct, stopFlowSchedulers, testFlow, testFlow, testFlowNonBlocking, testFlowNonBlocking
addBuilders, configureMuleContext, createMuleContext, createObject, createObject, disposeContext, disposeContextPerTest, doSetUpBeforeMuleContextCreation, doTearDown, doTearDownAfterMuleContextDispose, 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
clearExcludedFlag, clearRequestContext, clearTestCaseName, createTestTimeoutRule, dumpFilteredThreadsInTest, getTestTimeoutSecs, getTimeoutSystemProperty, initializeMuleTest, isDisabledInThisEnvironment, isDisabledInThisEnvironment, isExcluded, isFailOnTimeout, isOffline, isTestIncludedInExclusionFile, takeTestCaseName
protected static final String JMS_INPUT_QUEUE
protected static final String JMS_INPUT_QUEUE2
protected static final String JMS_DEAD_LETTER
protected final int timeout
protected MuleClient client
protected Latch messageRedeliveryExceptionFired
protected CounterCallback callback
public AbstractJmsRedeliveryTestCase(AbstractServiceAndFlowTestCase.ConfigVariant variant, String configResources)
public static Collection<Object[]> parameters()
protected void assertMessageInDlq() throws MuleException
MuleException
protected void assertMessageInDlqRollbackEs() throws Exception
Exception
protected void purgeQueue() throws MuleException
MuleException
protected void assertNoMessageInDlq(String location) throws MuleException
MuleException
public void cleanUpMaxRedelivery()
protected abstract int getMaxRedelivery()
protected abstract int getMaxRedeliveryAttempts()
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.