public class FlowDefaultProcessingStrategyTestCase extends FunctionalTestCase
Modifier and Type | Class and Description |
---|---|
static class |
FlowDefaultProcessingStrategyTestCase.ThreadSensingMessageProcessor |
static class |
FlowDefaultProcessingStrategyTestCase.ThreadSensingVMMessageDispatcher |
static class |
FlowDefaultProcessingStrategyTestCase.ThreadSensingVMMessageDispatcherFactory |
static class |
FlowDefaultProcessingStrategyTestCase.ThreadSensingVMMessageReceiver |
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 |
---|
FlowDefaultProcessingStrategyTestCase() |
Modifier and Type | Method and Description |
---|---|
protected void |
assertAllProcessingAsync(MuleMessage result) |
protected void |
assertAllProcessingInClientThread(MuleMessage result) |
protected void |
assertAllProcessingInRecieverThread(MuleMessage result) |
protected void |
assertSync(MuleMessage result) |
protected String |
getConfigFile() |
void |
testDispatchToOneWayInbound() |
void |
testDispatchToOneWayInboundTxOnly() |
void |
testDispatchToOneWayOutboundTxOnly() |
void |
testDispatchToOneWayTx() |
void |
testDispatchToRequestResponseInboundOneWayOutbound() |
void |
testRequestResponseInboundFailingOneWayOutbound() |
void |
testSendRequestResponseInbound() |
void |
testSendToOneWayInbound() |
void |
testSendToOneWayTx() |
void |
testSendToRequestResponseInboundOneWayOutbound() |
clearFlowAssertions, getBuilder, getComponent, getComponent, getConfigFiles, 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, doSetUp, 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, getTestHeader, getTestTimeoutSecs, getTimeoutSystemProperty, initializeMuleTest, isDisabledInThisEnvironment, isDisabledInThisEnvironment, isExcluded, isFailOnTimeout, isOffline, isTestIncludedInExclusionFile, takeTestCaseName
public FlowDefaultProcessingStrategyTestCase()
protected String getConfigFile()
getConfigFile
in class FunctionalTestCase
public void testDispatchToOneWayInbound() throws Exception
Exception
public void testDispatchToOneWayInboundTxOnly() throws Exception
Exception
public void testDispatchToOneWayOutboundTxOnly() throws Exception
Exception
public void testSendRequestResponseInbound() throws Exception
Exception
public void testDispatchToRequestResponseInboundOneWayOutbound() throws Exception
Exception
public void testSendToRequestResponseInboundOneWayOutbound() throws Exception
Exception
protected void assertAllProcessingInClientThread(MuleMessage result)
protected void assertAllProcessingInRecieverThread(MuleMessage result)
protected void assertSync(MuleMessage result)
protected void assertAllProcessingAsync(MuleMessage result)
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.