public abstract class AbstractEndpointBuilder extends Object implements EndpointBuilder, AnnotatedObject
PROPERTY_NAME
Constructor and Description |
---|
AbstractEndpointBuilder() |
public static final String PROPERTY_RESPONSE_TIMEOUT
public static final String PROPERTY_RESPONSE_PROPERTIES
protected URIBuilder uriBuilder
protected Connector connector
protected String name
protected TransactionConfig transactionConfig
protected Boolean deleteUnacceptedMessages
protected Boolean synchronous
protected MessageExchangePattern messageExchangePattern
protected Integer responseTimeout
protected String initialState
protected String encoding
protected Integer createConnector
protected RetryPolicyTemplate retryPolicyTemplate
protected String responsePropertiesList
protected EndpointMessageProcessorChainFactory messageProcessorsFactory
protected List<MessageProcessor> messageProcessors
protected List<MessageProcessor> responseMessageProcessors
protected List<Transformer> transformers
protected List<Transformer> responseTransformers
protected Boolean disableTransportTransformer
protected String mimeType
protected AbstractRedeliveryPolicy redeliveryPolicy
protected String registryId
protected MuleContext muleContext
protected transient Log logger
public InboundEndpoint buildInboundEndpoint() throws EndpointException, InitialisationException
EndpointBuilder
buildInboundEndpoint
in interface EndpointBuilder
EndpointException
InitialisationException
public OutboundEndpoint buildOutboundEndpoint() throws EndpointException, InitialisationException
EndpointBuilder
buildOutboundEndpoint
in interface EndpointBuilder
EndpointException
InitialisationException
protected void setPropertiesFromProperties(Map<Object,Object> properties)
protected InboundEndpoint doBuildInboundEndpoint() throws InitialisationException, EndpointException
protected InboundEndpoint createInboundEndpoint(EndpointURI endpointURI, List<MessageProcessor> mergedProcessors, List<MessageProcessor> mergedResponseProcessors, Connector connector) throws EndpointException
EndpointException
protected OutboundEndpoint doBuildOutboundEndpoint() throws InitialisationException, EndpointException
protected OutboundEndpoint createOutboundEndpoint(EndpointURI endpointURI, List<MessageProcessor> messageProcessors, List<MessageProcessor> responseMessageProcessors, Connector connector)
protected List<MessageProcessor> addTransformerProcessors(EndpointURI endpointURI) throws TransportFactoryException
TransportFactoryException
protected List<MessageProcessor> addResponseTransformerProcessors(EndpointURI endpointURI) throws TransportFactoryException
TransportFactoryException
protected void prepareToBuildEndpoint()
protected void checkInboundExchangePattern() throws EndpointException
EndpointException
protected void initExchangePatternFromConnectorDefault(TransportServiceDescriptor serviceDescriptor) throws EndpointException
EndpointException
public AbstractRedeliveryPolicy getRedeliveryPolicy()
protected RetryPolicyTemplate getRetryPolicyTemplate(Connector conn)
protected TransactionConfig getTransactionConfig()
protected TransactionConfig getDefaultTransactionConfig()
protected SecurityFilter getSecurityFilter()
protected EndpointSecurityFilter getDefaultSecurityFilter()
protected Connector getConnector() throws EndpointException
EndpointException
protected Connector getDefaultConnector() throws EndpointException
EndpointException
protected String getName(EndpointURI endpointURI)
protected boolean getDeleteUnacceptedMessages(Connector connector)
protected boolean getDefaultDeleteUnacceptedMessages(Connector connector)
protected int getResponseTimeout(Connector connector)
protected int getDefaultResponseTimeout(Connector connector)
protected List<Transformer> getTransformersFromUri(EndpointURI endpointURI) throws TransportFactoryException
TransportFactoryException
protected List<Transformer> getResponseTransformersFromUri(EndpointURI endpointURI) throws TransportFactoryException
TransportFactoryException
protected String getMimeType()
public void setMimeType(String mimeType)
protected String getScheme()
protected boolean isAlwaysCreateConnector()
public void setConnector(Connector connector)
setConnector
in interface EndpointBuilder
@Deprecated public void addTransformer(Transformer transformer)
addTransformer
in interface EndpointBuilder
@Deprecated public void setTransformers(List<Transformer> newTransformers)
setTransformers
in interface EndpointBuilder
protected EndpointMessageProcessorChainFactory getMessageProcessorsFactory()
protected EndpointMessageProcessorChainFactory getDefaultMessageProcessorsFactory()
@Deprecated public void addResponseTransformer(Transformer transformer)
addResponseTransformer
in interface EndpointBuilder
@Deprecated public void setResponseTransformers(List<Transformer> newResponseTransformers)
setResponseTransformers
in interface EndpointBuilder
public void addMessageProcessor(MessageProcessor messageProcessor)
addMessageProcessor
in interface EndpointBuilder
public void setMessageProcessors(List<MessageProcessor> newMessageProcessors)
setMessageProcessors
in interface EndpointBuilder
public List<MessageProcessor> getMessageProcessors()
public void addResponseMessageProcessor(MessageProcessor messageProcessor)
addResponseMessageProcessor
in interface EndpointBuilder
public void setResponseMessageProcessors(List<MessageProcessor> newResponseMessageProcessors)
setResponseMessageProcessors
in interface EndpointBuilder
public List<MessageProcessor> getResponseMessageProcessors()
protected boolean isDisableTransportTransformer()
protected boolean getDefaultDisableTransportTransformer()
public void setName(String name)
setName
in interface EndpointBuilder
public void setProperties(Map<Object,Object> properties)
setProperties
in interface EndpointBuilder
public void setProperty(Object key, Object value)
setProperty
in interface EndpointBuilder
key
- the property keyvalue
- the value of the propertypublic void setTransactionConfig(TransactionConfig transactionConfig)
setTransactionConfig
in interface EndpointBuilder
public void setDeleteUnacceptedMessages(boolean deleteUnacceptedMessages)
setDeleteUnacceptedMessages
in interface EndpointBuilder
public void setExchangePattern(MessageExchangePattern mep)
setExchangePattern
in interface EndpointBuilder
public void setResponseTimeout(int responseTimeout)
setResponseTimeout
in interface EndpointBuilder
public void setInitialState(String initialState)
setInitialState
in interface EndpointBuilder
public void setEncoding(String encoding)
setEncoding
in interface EndpointBuilder
public void setCreateConnector(int createConnector)
public void setRedeliveryPolicy(AbstractRedeliveryPolicy redeliveryPolicy)
public void setRegistryId(String registryId)
setRegistryId
in interface EndpointBuilder
public void setMuleContext(MuleContext muleContext)
setMuleContext
in interface MuleContextAware
public void setRetryPolicyTemplate(RetryPolicyTemplate retryPolicyTemplate)
setRetryPolicyTemplate
in interface EndpointBuilder
public void setDisableTransportTransformer(boolean disableTransportTransformer)
setDisableTransportTransformer
in interface EndpointBuilder
public URIBuilder getEndpointBuilder()
public void setURIBuilder(URIBuilder URIBuilder)
setURIBuilder
in interface EndpointBuilder
public Object clone() throws CloneNotSupportedException
clone
in interface EndpointBuilder
clone
in class Object
CloneNotSupportedException
public final Object getAnnotation(QName name)
AnnotatedObject
getAnnotation
in interface AnnotatedObject
public final Map<QName,Object> getAnnotations()
AnnotatedObject
getAnnotations
in interface AnnotatedObject
public final void setAnnotations(Map<QName,Object> newAnnotations)
AnnotatedObject
setAnnotations
in interface AnnotatedObject
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.