org.mule.transport.tcp.integration
Class StreamingCapacityTestCase

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.StreamingCapacityTestCase

public class StreamingCapacityTestCase
extends AbstractStreamingCapacityTestCase

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

StreamingCapacityTestCase(AbstractServiceAndFlowTestCase.ConfigVariant variant, String configResources, long size)

Method Summary

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

StreamingCapacityTestCase

public StreamingCapacityTestCase(AbstractServiceAndFlowTestCase.ConfigVariant variant,
                                 String configResources,
                                 long size)

Method Detail

parameters

public static Collection<Object[]> parameters()