org.mule.transport.tcp.integration
Class StreamingSynchCapacityTestCase

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.tcp.integration.AbstractStreamingCapacityTestCase
                      org.mule.transport.tcp.integration.StreamingSynchCapacityTestCase

public class StreamingSynchCapacityTestCase
extends AbstractStreamingCapacityTestCase

Tests a model for which synchonous=true for environment (was "and connector", but that is no longer possible). Not the same as issue MULE-1687. This will happily send 1GB while running in significantly less memory, but it takes some time. Since I'd like this to run in CI I will set at 100MB and test memory delta. But since memory usage could be around that anyway, this is may be a little unreliable. And there's no way to measure memory use directly in 1.4. We'll see... IMPORTANT - DO NOT RUN THIS TEST IN AN IDE WITH LOG LEVEL OF DEBUG. USE INFO TO SEE DIAGNOSTICS. OTHERWISE THE CONSOLE OUTPUT WILL BE SIMILAR SIZE TO DATA TRANSFERRED, CAUSING CONFUSNG AND PROBABLY FATAL MEMORY USE.

Nested Class Summary

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

AbstractServiceAndFlowTestCase.ConfigVariant

Field Summary

DynamicPort	port1
DynamicPort	port2

Fields inherited from class org.mule.transport.tcp.integration.AbstractStreamingCapacityTestCase

MESSAGES, ONE_GB, ONE_KB, ONE_MB

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

StreamingSynchCapacityTestCase(AbstractServiceAndFlowTestCase.ConfigVariant variant, String configResources)

Method Summary

protected boolean	isDisabledInThisEnvironment() Subclasses can override this method to skip the execution of the entire test class.
static Collection<Object[]>	parameters()

Methods inherited from class org.mule.transport.tcp.integration.AbstractStreamingCapacityTestCase

testSend

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, isExcluded, isFailOnTimeout, isOffline, isTestIncludedInExclusionFile

Methods inherited from class java.lang.Object

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

Field Detail

port1

public DynamicPort port1

port2

public DynamicPort port2

Constructor Detail

StreamingSynchCapacityTestCase

public StreamingSynchCapacityTestCase(AbstractServiceAndFlowTestCase.ConfigVariant variant,
                                      String configResources)

Method Detail

parameters

public static Collection<Object[]> parameters()

isDisabledInThisEnvironment

protected boolean isDisabledInThisEnvironment()

Description copied from class: AbstractMuleTestCase

Subclasses can override this method to skip the execution of the entire test class.

Overrides:

isDisabledInThisEnvironment in class AbstractMuleTestCase

Returns:

true if the test class should not be run.