public interface OutboundRouter extends Router
OutboundRouter
is used to control outbound routing behaviour for
an event. One or more Outbound routers can be associated with an
OutboundRouterCollection
and will be selected based on the filters
set on the individual Outbound Router.OutboundRouterCollection
PHASE_NAME
PHASE_NAME
Modifier and Type | Method and Description |
---|---|
void |
addEndpoint(OutboundEndpoint endpoint)
Adds an endpoint to this router
|
OutboundEndpoint |
getEndpoint(String name) |
List |
getEndpoints()
Gets a list of Endpoint instances associated with this router
|
String |
getReplyTo()
Gets the replyTo endpoint for any outgoing messages.
|
TransactionConfig |
getTransactionConfig() |
boolean |
isDynamicEndpoints()
Determines whether this router supports dynamic endpoint.
|
boolean |
isMatch(MuleMessage message)
Determines if the event should be processed by this router.
|
boolean |
removeEndpoint(OutboundEndpoint endpoint)
Removes a specific endpoint from the router
|
MuleMessage |
route(MuleMessage message,
MuleSession session,
boolean synchronous)
This method is responsible for routing the Message via the MuleSession.
|
void |
setEndpoints(List endpoints)
Sets a list of Endpoint instances associated with this router
|
void |
setReplyTo(String replyTo)
Sets the replyTo endpoint for any outgoing messages.
|
void |
setTransactionConfig(TransactionConfig transactionConfig) |
getRouterStatistics, setRouterStatistics
initialise
dispose
void setEndpoints(List endpoints)
endpoints
- a list of Endpoint instancesList getEndpoints()
void addEndpoint(OutboundEndpoint endpoint)
endpoint
- the endpoint to add to the routerboolean removeEndpoint(OutboundEndpoint endpoint)
endpoint
- the endpoint to removeMuleMessage route(MuleMessage message, MuleSession session, boolean synchronous) throws MessagingException
message
- the message to send via one or more endpoints on this routersession
- the session used to actually send the eventsynchronous
- whether the invocation process should be synchronous or notMessagingException
- if any errors occur during the sending of messagesFilteringOutboundRouter
,
ExceptionBasedRouter
,
MulticastingRouter
boolean isMatch(MuleMessage message) throws MessagingException
message
- the current message to evaluateMessagingException
- if the event cannot be evaluatedSelectiveConsumer
TransactionConfig getTransactionConfig()
void setTransactionConfig(TransactionConfig transactionConfig)
String getReplyTo()
void setReplyTo(String replyTo)
replyTo
- endpoint string to useboolean isDynamicEndpoints()
OutboundEndpoint getEndpoint(String name)
name
- the Endpoint identifierCopyright © 2003–2013 MuleSource, Inc.. All rights reserved.