org.mule.transport.udp.functional

Class UdpConnectorFunctionalTestCase

java.lang.Object

org.mule.tck.junit4.AbstractMuleTestCase

org.mule.tck.junit4.AbstractMuleContextTestCase

org.mule.tck.junit4.FunctionalTestCase

org.mule.tck.AbstractServiceAndFlowTestCase

org.mule.transport.udp.functional.UdpConnectorFunctionalTestCase

public class UdpConnectorFunctionalTestCase
extends AbstractServiceAndFlowTestCase

Nested Class Summary

Nested classes/interfaces inherited from class org.mule.tck.AbstractServiceAndFlowTestCase

AbstractServiceAndFlowTestCase.ConfigVariant

Field Summary

Fields

Modifier and Type	Field and Description
static long	BETWEEN_BATCH_PAUSE
static int	MAX_NUMBER_OF_BATCHES
static long	MAX_PAUSE_PERIOD
static String	MESSAGE
static long	MIN_PAUSE_PERIOD
static int	TOTAL_MESSAGE_COUNT

Fields inherited from class org.mule.tck.AbstractServiceAndFlowTestCase

configResources, variant

Fields inherited from class org.mule.tck.junit4.AbstractMuleContextTestCase

callbackCalled, CLASSNAME_ANNOTATIONS_CONFIG_BUILDER, IGNORED_DOT_MULE_DIRS, LOCK_TIMEOUT, muleContext, RECEIVE_TIMEOUT, TEST_MESSAGE, TEST_PAYLOAD, WORKING_DIRECTORY_SYSTEM_PROPERTY_KEY, workingDirectory

Fields inherited from class org.mule.tck.junit4.AbstractMuleTestCase

DEFAULT_TEST_TIMEOUT_SECS, globalTimeout, logger, name, TEST_TIMEOUT_SYSTEM_PROPERTY, TESTING_MODE_PROPERTY_NAME

Constructor Summary

Constructors

Constructor and Description
UdpConnectorFunctionalTestCase(AbstractServiceAndFlowTestCase.ConfigVariant variant, String configResources)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	doTestSome(int numberOfMessages, int burst)
static Collection<Object[]>	parameters()
void	testMany() We try progressively smaller batches to see if there are issues with internal buffers.

Methods inherited from class org.mule.tck.AbstractServiceAndFlowTestCase

doSetUp, doSetUpForFlow, doSetUpForService, getConfigFile, getConfigFiles, getTestHeader

Methods inherited from class org.mule.tck.junit4.FunctionalTestCase

clearFlowAssertions, getBuilder, getComponent, getComponent, getConfigResources, getFlowConstruct, getFunctionalTestComponent, getSubFlow, loadResource, loadResourceAsString, lookupFlowConstruct, runFlow, runFlow, runFlow, runFlowAndExpect, runFlowAndExpectProperty, runFlowWithPayloadAndExpect, runSchedulersOnce, stopFlowConstruct, stopFlowSchedulers, testFlow, testFlow

Methods inherited from class org.mule.tck.junit4.AbstractMuleContextTestCase

addBuilders, configureMuleContext, createMuleContext, createObject, createObject, disposeContext, disposeContextPerTest, 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

Methods inherited from class org.mule.tck.junit4.AbstractMuleTestCase

clearExcludedFlag, clearRequestContext, clearTestCaseName, createTestTimeoutRule, dumpFilteredThreadsInTest, getTestTimeoutSecs, getTimeoutSystemProperty, initializeMuleTest, isDisabledInThisEnvironment, isDisabledInThisEnvironment, isExcluded, isFailOnTimeout, isOffline, isTestIncludedInExclusionFile, takeTestCaseName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MESSAGE

public static final String MESSAGE

See Also:

Constant Field Values

TOTAL_MESSAGE_COUNT

public static final int TOTAL_MESSAGE_COUNT

See Also:

Constant Field Values

MAX_NUMBER_OF_BATCHES

public static final int MAX_NUMBER_OF_BATCHES

See Also:

Constant Field Values

MAX_PAUSE_PERIOD

public static final long MAX_PAUSE_PERIOD

See Also:

Constant Field Values

MIN_PAUSE_PERIOD

public static final long MIN_PAUSE_PERIOD

See Also:

Constant Field Values

BETWEEN_BATCH_PAUSE

public static final long BETWEEN_BATCH_PAUSE

See Also:

Constant Field Values

Constructor Detail

UdpConnectorFunctionalTestCase

public UdpConnectorFunctionalTestCase(AbstractServiceAndFlowTestCase.ConfigVariant variant,
                              String configResources)

Method Detail

parameters

public static Collection<Object[]> parameters()

testMany

public void testMany()
              throws Exception

We try progressively smaller batches to see if there are issues with internal buffers. If we don't get 100% success eventually, we fail.

Throws:

Exception

doTestSome

protected boolean doTestSome(int numberOfMessages,
                 int burst)
                      throws Exception

Parameters:

numberOfMessages - Total number of tests

burst - Number of mesages to send between wait periods

Returns:

true if all messages received

Throws:

Exception