org.mule.endpoint.outbound

Class OutboundEndpointTestCase

java.lang.Object

org.mule.tck.junit4.AbstractMuleTestCase

org.mule.tck.junit4.AbstractMuleContextTestCase

org.mule.endpoint.AbstractMessageProcessorTestCase

org.mule.endpoint.outbound.OutboundEndpointTestCase

public class OutboundEndpointTestCase
extends AbstractMessageProcessorTestCase

Tests flow of messages from MessageProcessor.process(MuleEvent) down to AbstractMessageDispatcher and the chain of MessageProcessor's that implement the outbound endpoint processing.

Nested Class Summary

Nested classes/interfaces inherited from class org.mule.endpoint.AbstractMessageProcessorTestCase

AbstractMessageProcessorTestCase.ExceptionThrowingMessageProcessr, AbstractMessageProcessorTestCase.ObjectAwareProcessor, AbstractMessageProcessorTestCase.TestEndpointMessageNotificationListener, AbstractMessageProcessorTestCase.TestExceptionListener, AbstractMessageProcessorTestCase.TestFilter, AbstractMessageProcessorTestCase.TestListener, AbstractMessageProcessorTestCase.TestSecurityNotificationListener

Field Summary

Fields

Modifier and Type	Field and Description
protected org.mule.endpoint.outbound.OutboundEndpointTestCase.FakeMessageDispatcher	dispacher
protected MuleEvent	testOutboundEvent

Fields inherited from class org.mule.endpoint.AbstractMessageProcessorTestCase

echoEventAnswer, RESPONSE_MESSAGE, responseMessage, TEST_URI

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
OutboundEndpointTestCase()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	assertEqualMessages(MuleMessage expect, MuleMessage actual)
protected void	assertMessageNotSent()
protected MuleEvent	assertMessageSent(boolean sync)
protected MuleEvent	assertMessageSentSame(boolean sync)
protected OutboundEndpoint	createOutboundEndpoint(Filter filter, SecurityFilter securityFilter, Transformer in, Transformer response, MessageExchangePattern exchangePattern, TransactionConfig txConfig)
protected OutboundEndpoint	createOutboundEndpoint(String uri, Filter filter, SecurityFilter securityFilter, Transformer in, Transformer response, MessageExchangePattern exchangePattern, TransactionConfig txConfig)
void	testConnectorNotStarted()
void	testDefaultFlowAsync()
void	testDefaultFlowNonBlocking()
void	testDefaultFlowNonBlockingError()
void	testDefaultFlowSync()
void	testDispatchNotfication()
void	testObjectAwareInjection()
void	testSecurityFilterAccept()
void	testSecurityFilterNotAccept()
void	testSendNotfication()
void	testTimeoutSetOnEvent()
void	testTransformers()

Methods inherited from class org.mule.endpoint.AbstractMessageProcessorTestCase

configureMuleContext, createTestInboundEndpoint, createTestInboundEndpoint, createTestInboundEndpoint, createTestInboundEvent, createTestOutboundEndpoint, createTestOutboundEndpoint, createTestOutboundEndpoint, createTestOutboundEndpoint, createTestOutboundEvent, createTestOutboundEvent, createTestResponseMuleMessage, customizeEndpointBuilder, doSetUp

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

addBuilders, createMuleContext, createObject, createObject, disposeContext, disposeContextPerTest, doSetUpBeforeMuleContextCreation, doTearDown, doTearDownAfterMuleContextDispose, getBuilder, getConfigurationResources, getFileInsideWorkingDirectory, getNonBlockingResponse, getNonBlockingTestEventUsingFlow, getSensingNullMessageProcessor, getStartUpProperties, getTestConnector, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEventContext, getTestEventContext, getTestEventUsingFlow, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestMuleMessage, 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, getTestHeader, 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

dispacher

protected org.mule.endpoint.outbound.OutboundEndpointTestCase.FakeMessageDispatcher dispacher

testOutboundEvent

protected MuleEvent testOutboundEvent

Constructor Detail

OutboundEndpointTestCase

public OutboundEndpointTestCase()

Method Detail

testDefaultFlowSync

public void testDefaultFlowSync()
                         throws Exception

Throws:

Exception

testDefaultFlowNonBlocking

public void testDefaultFlowNonBlocking()
                                throws Exception

Throws:

Exception

testDefaultFlowNonBlockingError

public void testDefaultFlowNonBlockingError()
                                     throws Exception

Throws:

Exception

testDefaultFlowAsync

public void testDefaultFlowAsync()
                          throws Exception

Throws:

Exception

testSecurityFilterAccept

public void testSecurityFilterAccept()
                              throws Exception

Throws:

Exception

testSecurityFilterNotAccept

public void testSecurityFilterNotAccept()
                                 throws Exception

Throws:

Exception

testSendNotfication

public void testSendNotfication()
                         throws Exception

Throws:

Exception

testDispatchNotfication

public void testDispatchNotfication()
                             throws Exception

Throws:

Exception

testTransformers

public void testTransformers()
                      throws Exception

Throws:

Exception

testConnectorNotStarted

public void testConnectorNotStarted()
                             throws Exception

Throws:

Exception

testTimeoutSetOnEvent

public void testTimeoutSetOnEvent()
                           throws Exception

Throws:

Exception

testObjectAwareInjection

public void testObjectAwareInjection()
                              throws Exception

Throws:

Exception

assertMessageSent

protected MuleEvent assertMessageSent(boolean sync)
                               throws MuleException

Throws:

MuleException

assertMessageSentSame

protected MuleEvent assertMessageSentSame(boolean sync)
                                   throws MuleException

Throws:

MuleException

assertMessageNotSent

protected void assertMessageNotSent()
                             throws MuleException

Throws:

MuleException

assertEqualMessages

protected void assertEqualMessages(MuleMessage expect,
                       MuleMessage actual)

createOutboundEndpoint

protected OutboundEndpoint createOutboundEndpoint(String uri,
                                      Filter filter,
                                      SecurityFilter securityFilter,
                                      Transformer in,
                                      Transformer response,
                                      MessageExchangePattern exchangePattern,
                                      TransactionConfig txConfig)
                                           throws Exception

Throws:

Exception

createOutboundEndpoint

protected OutboundEndpoint createOutboundEndpoint(Filter filter,
                                      SecurityFilter securityFilter,
                                      Transformer in,
                                      Transformer response,
                                      MessageExchangePattern exchangePattern,
                                      TransactionConfig txConfig)
                                           throws Exception

Throws:

Exception