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

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

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

DEFAULT_TEST_TIMEOUT_SECS, globalTimeout, logger, name, TEST_TIMEOUT_SYSTEM_PROPERTY

Constructor Summary

UdpConnectorFunctionalTestCase(AbstractServiceAndFlowTestCase.ConfigVariant variant, String configResources)

Method Summary

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, getConfigResources, getTestHeader

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

clearFlowAssertions, getBuilder, getComponent, getComponent, getFlowConstruct, getFunctionalTestComponent, loadResource, loadResourceAsString, stopFlowConstruct, testFlow, testFlow

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

addBuilders, configureMuleContext, createMuleContext, createObject, createObject, disposeContext, disposeContextPerTest, doTearDown, getConfigurationResources, getSensingNullMessageProcessor, getStartUpProperties, getTestConnector, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEventContext, getTestEventContext, getTestEventUsingFlow, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestService, getTestService, getTestService, getTestSession, getTestTransactedInboundEndpoint, getTestTransformer, getTriggerableMessageSource, getTriggerableMessageSource, initialiseObject, isDisposeContextPerClass, isGracefulShutdown, isStartContext, setDisposeContextPerClass, setStartContext, setUpMuleContext

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

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

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