public class FlowAynchronousProcessingStrategyTestCase extends FlowDefaultProcessingStrategyTestCase
FlowDefaultProcessingStrategyTestCase.ThreadSensingMessageProcessor, FlowDefaultProcessingStrategyTestCase.ThreadSensingVMMessageDispatcher, FlowDefaultProcessingStrategyTestCase.ThreadSensingVMMessageDispatcherFactory, 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 |
---|
FlowAynchronousProcessingStrategyTestCase() |
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 |
testDispatchToOneWayInboundTxOnly() |
void |
testDispatchToOneWayTx() |
void |
testDispatchToRequestResponseInboundOneWayOutbound() |
void |
testRequestResponseInboundFailingOneWayOutbound() |
void |
testSendRequestResponseInbound() |
void |
testSendToOneWayTx() |
void |
testSendToRequestResponseInboundOneWayOutbound() |
testDispatchToOneWayInbound, testDispatchToOneWayOutboundTxOnly, testSendToOneWayInbound
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 FlowAynchronousProcessingStrategyTestCase()
protected String getConfigFile()
getConfigFile
in class FlowDefaultProcessingStrategyTestCase
public void testDispatchToOneWayInboundTxOnly() throws Exception
testDispatchToOneWayInboundTxOnly
in class FlowDefaultProcessingStrategyTestCase
Exception
public void testDispatchToOneWayTx() throws Exception
testDispatchToOneWayTx
in class FlowDefaultProcessingStrategyTestCase
Exception
public void testSendToOneWayTx() throws Exception
testSendToOneWayTx
in class FlowDefaultProcessingStrategyTestCase
Exception
public void testSendRequestResponseInbound() throws Exception
testSendRequestResponseInbound
in class FlowDefaultProcessingStrategyTestCase
Exception
public void testDispatchToRequestResponseInboundOneWayOutbound() throws Exception
testDispatchToRequestResponseInboundOneWayOutbound
in class FlowDefaultProcessingStrategyTestCase
Exception
public void testSendToRequestResponseInboundOneWayOutbound() throws Exception
testSendToRequestResponseInboundOneWayOutbound
in class FlowDefaultProcessingStrategyTestCase
Exception
protected void assertAllProcessingInClientThread(MuleMessage result)
assertAllProcessingInClientThread
in class FlowDefaultProcessingStrategyTestCase
protected void assertAllProcessingInRecieverThread(MuleMessage result)
assertAllProcessingInRecieverThread
in class FlowDefaultProcessingStrategyTestCase
protected void assertSync(MuleMessage result)
assertSync
in class FlowDefaultProcessingStrategyTestCase
protected void assertAllProcessingAsync(MuleMessage result)
assertAllProcessingAsync
in class FlowDefaultProcessingStrategyTestCase
public void testRequestResponseInboundFailingOneWayOutbound() throws Exception
testRequestResponseInboundFailingOneWayOutbound
in class FlowDefaultProcessingStrategyTestCase
Exception
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.