public class WatermarkPollingTestCase extends FunctionalTestCase
Modifier and Type | Class and Description |
---|---|
static class |
WatermarkPollingTestCase.FooComponent |
static class |
WatermarkPollingTestCase.PollStopper |
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 |
---|
WatermarkPollingTestCase() |
Modifier and Type | Method and Description |
---|---|
void |
cleanFoo() |
void |
failingFlowWithCatchedExceptionWatermark()
Scenario:
|
void |
failingFlowWithWatermark()
Scenario:
|
void |
firstSelectorWithIterator() |
void |
firstSelectorWithList() |
protected String |
getConfigFile() |
void |
lastSelectorWithIterator() |
void |
lastSelectorWithList() |
void |
maxSelectorWithIterator() |
void |
maxSelectorWithList() |
void |
minSelectorWithIterator() |
void |
minSelectorWithList() |
void |
pollChangeKeyValueWithNoKeyInTheObjectStore()
Scenario:
|
void |
pollUsingWatermark()
Scenario:
|
void |
pollWithNoKeyInTheObjectStore()
Scenario:
|
void |
testThatOsIsUserObjectStore() |
void |
usingWatermarkFlowWithNullUpdateValue() |
void |
watermarkWithAsyncProcessing()
Scenario:
|
void |
watermarkWithKeyAsAnExpression()
Scenario:
|
void |
watermarkWithNullDefaultExpression() |
void |
watermarkWithObjectStore()
Scenario:
|
void |
watermarkWithUpdateExpression()
Scenario:
|
clearFlowAssertions, getBuilder, getComponent, getComponent, getConfigFiles, getConfigResources, getFlowConstruct, getFunctionalTestComponent, getSubFlow, loadResource, loadResourceAsString, lookupFlowConstruct, runFlow, runFlow, runFlow, runFlowAndExpect, runFlowAndExpectProperty, runFlowWithPayloadAndExpect, runSchedulersOnce, stopFlowConstruct, stopFlowSchedulers, testFlow, testFlow
addBuilders, configureMuleContext, createMuleContext, createObject, createObject, disposeContext, disposeContextPerTest, doSetUp, doSetUpBeforeMuleContextCreation, doTearDown, doTearDownAfterMuleContextDispose, 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
protected String getConfigFile()
getConfigFile
in class FunctionalTestCase
public void cleanFoo()
public void testThatOsIsUserObjectStore()
public void pollWithNoKeyInTheObjectStore() throws Exception
No Object store Defined. No Update Expression defined No Key present in the Object Store
Result:Executes the default value expression of watermark, registers it as a flow var, stores that value in the OS at the end of the flow.
Exception
public void pollChangeKeyValueWithNoKeyInTheObjectStore() throws Exception
No object store defined No update expression defined. No Object store Key present The user changes the watermark value in the flow.
Result:Executes the default value expression of watermark, registers it as a flow var, stores that value in the OS at the end of the flow but The key is stored in the object store with the value that the user set in the flow variable
Exception
public void pollUsingWatermark() throws Exception
No object store defined No update expression defined. The key is already present in the Object store The user changes the watermark value in the flow.
Result:Retrieves the key value from the Object store, registers it as a flow var, stores that value in the OS at the end of the flow but The key is stored in the object store with the value that the user set in the flow variable.
Extra validation. The User uses the watermark value in the poll element.Exception
public void watermarkWithKeyAsAnExpression() throws Exception
No object store defined No update expression defined. The key is already present in the Object store The user changes the watermark value in the flow. The specified Watermark key is an expression
Result:Retrieves the key value from the Object store, registers it as a flow var, stores that value in the OS at the end of the flow. The key expression is evaluated twice, at the beginning of the message source and at the end of the flow
Exception
public void watermarkWithUpdateExpression() throws Exception
No object store defined The update expression is defined. The key is already present in the Object store
Result: Retrieves the key value from the Object store, registers it as a flow var, stores that value in the OS at the end of the flow but The key is stored in the object store with the result of the update expression specified in watermarkException
public void watermarkWithObjectStore() throws Exception
Object store defined The update expression is defined. The key is already present in the Object store The flow fails to execute
Result: The watermark is not updatedException
public void failingFlowWithWatermark() throws Exception
No object store defined The update expression is defined. The key is already present in the Object store The flow fails to execute
Result: The watermark is not updatedException
public void failingFlowWithCatchedExceptionWatermark() throws Exception
No object store defined The update expression is defined. The key is already present in the Object store The flow fails to execute but it is catched in a catch-exception-strategy
Result: The watermark is updated with the value that is set in the catch exception strategyException
public void watermarkWithAsyncProcessing() throws Exception
Watermark is configured in an async flow
Result: It fails the executionException
public void watermarkWithNullDefaultExpression() throws Exception
Exception
public void usingWatermarkFlowWithNullUpdateValue() throws Exception
Exception
public void firstSelectorWithIterator() throws Exception
Exception
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.