|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.mule.endpoint.DynamicOutboundEndpoint
public class DynamicOutboundEndpoint
An Outbound endpoint who's URI is a template used to created new non dynamic endpoints based on the current message. This allows for the destination of a message to change based on the contents of the message. Note that this endpoint ONLY substitutes the URI, but other config elements such as the transformers, filters, etc do not change. You cannot change an endpoint scheme dynamically so you can't switch between HTTP and JMS for example using the same dynamic endpoint.
Field Summary | |
---|---|
static String |
DYNAMIC_URI_PLACEHOLDER
|
protected Log |
logger
|
protected String |
uriTemplate
The URI template used to construct the actual URI to send the message to. |
Fields inherited from interface org.mule.api.endpoint.ImmutableEndpoint |
---|
INITIAL_STATE_STARTED, INITIAL_STATE_STOPPED |
Constructor Summary | |
---|---|
DynamicOutboundEndpoint(EndpointBuilder builder,
String uriTemplate)
|
Method Summary | |
---|---|
boolean |
equals(Object o)
|
String |
getAddress()
This returns the address of the endpoint. |
Connector |
getConnector()
The endpoint that will be used to send the message on. |
String |
getEncoding()
Decides the encoding to be used for events received by this endpoint |
String |
getEndpointBuilderName()
The name of the endpoint builder used to create this endpoint. |
EndpointURI |
getEndpointURI()
This specifess the communication endpointUri. |
protected EndpointURI |
getEndpointURIForMessage(MuleEvent event)
|
MessageExchangePattern |
getExchangePattern()
|
Filter |
getFilter()
The filter to apply to incoming messages. |
String |
getInitialState()
Sets the state the endpoint will be loaded in. |
List<MessageProcessor> |
getMessageProcessors()
|
EndpointMessageProcessorChainFactory |
getMessageProcessorsFactory()
|
String |
getMimeType()
Return the mime type defined for the endpoint, if any |
MuleContext |
getMuleContext()
|
String |
getName()
Gets the name of the object |
Map |
getProperties()
Returns any properties set on this endpoint |
Object |
getProperty(Object key)
Retrieves a property set on the endpoint |
String |
getProtocol()
The transport protocol name that the message endpoint communicates over. |
AbstractRedeliveryPolicy |
getRedeliveryPolicy()
Return the endpoint's redelivery policy, if any |
List<MessageProcessor> |
getResponseMessageProcessors()
|
List<String> |
getResponseProperties()
|
int |
getResponseTimeout()
The timeout value for waiting for a response from a remote invocation or back channel. |
List<Transformer> |
getResponseTransformers()
The transformers used when a response is returned from invoking this endpoint. |
RetryPolicyTemplate |
getRetryPolicyTemplate()
The retry policy on the endpoint configures how retries are handled. |
EndpointSecurityFilter |
getSecurityFilter()
Returns an EndpointSecurityFilter for this endpoint. |
TransactionConfig |
getTransactionConfig()
Returns the transaction configuration for this endpoint |
List<Transformer> |
getTransformers()
Transformers are responsible for transforming data when it is received or sent by the component (depending on whether this endpoint is a receiver or not). |
int |
hashCode()
|
boolean |
isDeleteUnacceptedMessages()
If a filter is configured on this endpoint, this property will determine if message that are not excepted by the filter are deleted |
boolean |
isDisableTransportTransformer()
|
boolean |
isProtocolSupported(String protocol)
|
boolean |
isReadOnly()
|
protected String |
parseURIString(String uri,
MuleMessage message)
|
MuleEvent |
process(MuleEvent event)
Invokes the MessageProcessor. |
protected void |
validateUriTemplate(String uri)
|
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String DYNAMIC_URI_PLACEHOLDER
protected final transient Log logger
protected String uriTemplate
Constructor Detail |
---|
public DynamicOutboundEndpoint(EndpointBuilder builder, String uriTemplate) throws MalformedEndpointException
MalformedEndpointException
Method Detail |
---|
protected void validateUriTemplate(String uri) throws MalformedEndpointException
MalformedEndpointException
protected EndpointURI getEndpointURIForMessage(MuleEvent event) throws DispatchException
DispatchException
protected String parseURIString(String uri, MuleMessage message)
public MuleEvent process(MuleEvent event) throws MuleException
MessageProcessor
process
in interface MessageProcessor
event
- MuleEvent to be processed
MuleException
public boolean equals(Object o)
equals
in class Object
public int hashCode()
hashCode
in class Object
public Connector getConnector()
ImmutableEndpoint
getConnector
in interface ImmutableEndpoint
public EndpointURI getEndpointURI()
ImmutableEndpoint
getEndpointURI
in interface ImmutableEndpoint
public AbstractRedeliveryPolicy getRedeliveryPolicy()
ImmutableEndpoint
getRedeliveryPolicy
in interface ImmutableEndpoint
public String getAddress()
ImmutableEndpoint
getAddress
in interface ImmutableEndpoint
public RetryPolicyTemplate getRetryPolicyTemplate()
ImmutableEndpoint
getRetryPolicyTemplate
in interface ImmutableEndpoint
public String getEncoding()
ImmutableEndpoint
getEncoding
in interface ImmutableEndpoint
public String getMimeType()
ImmutableEndpoint
getMimeType
in interface ImmutableEndpoint
public Filter getFilter()
ImmutableEndpoint
getFilter
in interface ImmutableEndpoint
public String getInitialState()
ImmutableEndpoint
getInitialState
in interface ImmutableEndpoint
public MuleContext getMuleContext()
getMuleContext
in interface ImmutableEndpoint
public String getName()
NamedObject
getName
in interface NamedObject
public Map getProperties()
ImmutableEndpoint
getProperties
in interface ImmutableEndpoint
public Object getProperty(Object key)
ImmutableEndpoint
getProperty
in interface ImmutableEndpoint
key
- the name of the property
public String getProtocol()
ImmutableEndpoint
getProtocol
in interface ImmutableEndpoint
public int getResponseTimeout()
ImmutableEndpoint
getResponseTimeout
in interface ImmutableEndpoint
public List<Transformer> getResponseTransformers()
ImmutableEndpoint
getResponseTransformers
in interface ImmutableEndpoint
public EndpointMessageProcessorChainFactory getMessageProcessorsFactory()
getMessageProcessorsFactory
in interface ImmutableEndpoint
public List<MessageProcessor> getMessageProcessors()
getMessageProcessors
in interface ImmutableEndpoint
public List<MessageProcessor> getResponseMessageProcessors()
getResponseMessageProcessors
in interface ImmutableEndpoint
public EndpointSecurityFilter getSecurityFilter()
ImmutableEndpoint
getSecurityFilter
in interface ImmutableEndpoint
EndpointSecurityFilter
public TransactionConfig getTransactionConfig()
ImmutableEndpoint
getTransactionConfig
in interface ImmutableEndpoint
public List<Transformer> getTransformers()
ImmutableEndpoint
getTransformers
in interface ImmutableEndpoint
public boolean isDeleteUnacceptedMessages()
ImmutableEndpoint
isDeleteUnacceptedMessages
in interface ImmutableEndpoint
public boolean isReadOnly()
isReadOnly
in interface ImmutableEndpoint
public MessageExchangePattern getExchangePattern()
getExchangePattern
in interface ImmutableEndpoint
public List<String> getResponseProperties()
getResponseProperties
in interface OutboundEndpoint
public String getEndpointBuilderName()
ImmutableEndpoint
getEndpointBuilderName
in interface ImmutableEndpoint
public boolean isProtocolSupported(String protocol)
isProtocolSupported
in interface ImmutableEndpoint
public boolean isDisableTransportTransformer()
isDisableTransportTransformer
in interface ImmutableEndpoint
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |