public class DynamicAll extends Object implements MessageProcessor, MuleContextAware, Initialisable
DynamicRouteResolver
.
The message will be route to all the routes returned by DynamicRouteResolver
and then all the results will be aggregated.PHASE_NAME
Constructor and Description |
---|
DynamicAll() |
Modifier and Type | Method and Description |
---|---|
void |
initialise()
Method used to perform any initialisation work.
|
MuleEvent |
process(MuleEvent event)
Invokes the MessageProcessor.
|
void |
setDynamicRouteResolver(DynamicRouteResolver routeResolver) |
void |
setMuleContext(MuleContext context) |
void |
setResultAggregator(RouterResultsHandler routerResultsHandler) |
public void initialise() throws InitialisationException
Initialisable
InitialisationException
should be thrown,
causing the Mule instance to shutdown. If the error is recoverable, say by
retrying to connect, a RecoverableException
should be thrown.
There is no guarantee that by throwing a Recoverable exception that the Mule
instance will not shut down.initialise
in interface Initialisable
InitialisationException
- if a fatal error occurs causing the Mule instance to shutdownRecoverableException
- if an error occurs that can be recovered frompublic MuleEvent process(MuleEvent event) throws MuleException
MessageProcessor
process
in interface MessageProcessor
event
- MuleEvent to be processedMuleException
public void setMuleContext(MuleContext context)
setMuleContext
in interface MuleContextAware
public void setDynamicRouteResolver(DynamicRouteResolver routeResolver)
routeResolver
- custom route resolver to usepublic void setResultAggregator(RouterResultsHandler routerResultsHandler)
routerResultsHandler
- result aggregator to use after routing through the routesCopyright © 2003–2015 MuleSoft, Inc.. All rights reserved.