public class DefaultOutboundEndpoint extends AbstractEndpoint implements OutboundEndpoint
logger, PROPERTY_PROCESS_SYNCHRONOUSLY, retryPolicyTemplate
INITIAL_STATE_STARTED, INITIAL_STATE_STOPPED
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
DefaultOutboundEndpoint(Connector connector,
EndpointURI endpointUri,
String name,
Map properties,
TransactionConfig transactionConfig,
boolean deleteUnacceptedMessage,
MessageExchangePattern messageExchangePattern,
int responseTimeout,
String initialState,
String endpointEncoding,
String endpointBuilderName,
MuleContext muleContext,
RetryPolicyTemplate retryPolicyTemplate,
AbstractRedeliveryPolicy redeliveryPolicy,
String responsePropertiesList,
EndpointMessageProcessorChainFactory messageProcessorsFactory,
List<MessageProcessor> messageProcessors,
List<MessageProcessor> responseMessageProcessors,
boolean disableTransportTransformer,
String endpointMimeType) |
Modifier and Type | Method and Description |
---|---|
protected MessageProcessor |
createMessageProcessorChain(FlowConstruct flowContruct) |
List<String> |
getResponseProperties() |
boolean |
isDynamic() |
MuleEvent |
process(MuleEvent event)
Invokes the MessageProcessor.
|
void |
setMessagingExceptionHandler(MessagingExceptionHandler messagingExceptionHandler) |
dispose, equal, equals, getAddress, getAnnotation, getAnnotations, getConnector, getEncoding, getEndpointBuilderName, getEndpointURI, getExchangePattern, getFilter, getInitialState, getMessageProcessorChain, getMessageProcessors, getMessageProcessorsFactory, getMimeType, getMuleContext, getName, getProperties, getProperty, getProtocol, getRedeliveryPolicy, getResponseMessageProcessors, getResponseTimeout, getResponseTransformers, getRetryPolicyTemplate, getSecurityFilter, getTransactionConfig, getTransformers, hashCode, isDeleteUnacceptedMessages, isDisableTransportTransformer, isProtocolSupported, isReadOnly, setAnnotations, toString
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getAddress, getConnector, getEncoding, getEndpointBuilderName, getEndpointURI, getExchangePattern, getFilter, getInitialState, getMessageProcessors, getMessageProcessorsFactory, getMimeType, getMuleContext, getProperties, getProperty, getProtocol, getRedeliveryPolicy, getResponseMessageProcessors, getResponseTimeout, getResponseTransformers, getRetryPolicyTemplate, getSecurityFilter, getTransactionConfig, getTransformers, isDeleteUnacceptedMessages, isDisableTransportTransformer, isProtocolSupported, isReadOnly
getName
public DefaultOutboundEndpoint(Connector connector, EndpointURI endpointUri, String name, Map properties, TransactionConfig transactionConfig, boolean deleteUnacceptedMessage, MessageExchangePattern messageExchangePattern, int responseTimeout, String initialState, String endpointEncoding, String endpointBuilderName, MuleContext muleContext, RetryPolicyTemplate retryPolicyTemplate, AbstractRedeliveryPolicy redeliveryPolicy, String responsePropertiesList, EndpointMessageProcessorChainFactory messageProcessorsFactory, List<MessageProcessor> messageProcessors, List<MessageProcessor> responseMessageProcessors, boolean disableTransportTransformer, String endpointMimeType)
public List<String> getResponseProperties()
getResponseProperties
in interface OutboundEndpoint
public boolean isDynamic()
isDynamic
in interface OutboundEndpoint
public MuleEvent process(MuleEvent event) throws MuleException
MessageProcessor
process
in interface MessageProcessor
event
- MuleEvent to be processedMuleException
protected MessageProcessor createMessageProcessorChain(FlowConstruct flowContruct) throws MuleException
createMessageProcessorChain
in class AbstractEndpoint
MuleException
public void setMessagingExceptionHandler(MessagingExceptionHandler messagingExceptionHandler)
setMessagingExceptionHandler
in interface MessagingExceptionHandlerAware
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.