org.mule.routing
Class AsynchronousUntilSuccessfulProcessingStrategy
java.lang.Object
org.mule.routing.AbstractUntilSuccessfulProcessingStrategy
org.mule.routing.AsynchronousUntilSuccessfulProcessingStrategy
- All Implemented Interfaces:
- Initialisable, Startable, Stoppable, UntilSuccessfulProcessingStrategy
public class AsynchronousUntilSuccessfulProcessingStrategy
- extends AbstractUntilSuccessfulProcessingStrategy
- implements Initialisable, Startable, Stoppable
Until successful asynchronous processing strategy.
It will return successfully to the flow executing the router once it was able to
store the message in the object store.
After that it will asynchronously try to process the message through the internal route.
If route was not successfully executed after the configured retry count then the message
will be routed to the defined dead letter queue route or in case there is no dead letter
queue route then it will be handled by the flow exception strategy.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
logger
protected transient Log logger
AsynchronousUntilSuccessfulProcessingStrategy
public AsynchronousUntilSuccessfulProcessingStrategy()
initialise
public void initialise()
throws InitialisationException
- Description copied from interface:
Initialisable
- Method used to perform any initialisation work. If a fatal error occurs during
initialisation an
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.
- Specified by:
initialise
in interface Initialisable
- Throws:
InitialisationException
- if a fatal error occurs causing the Mule instance to shutdown
RecoverableException
- if an error occurs that can be recovered from
start
public void start()
- Specified by:
start
in interface Startable
stop
public void stop()
- Specified by:
stop
in interface Stoppable
route
public MuleEvent route(MuleEvent event)
throws MessagingException
- Specified by:
route
in interface UntilSuccessfulProcessingStrategy
- Parameters:
event
- the message to be routed through the until-successful router.
- Returns:
- the return event from the until-successful execution.
- Throws:
MessagingException
- exception thrown during until-successful execution.
buildQueueKey
public static Serializable buildQueueKey(MuleEvent muleEvent)
threadSafeCopy
protected MuleEvent threadSafeCopy(MuleEvent event)
Copyright © 2003-2014 MuleSoft, Inc.. All Rights Reserved.