org.mule.routing

Class AbstractUntilSuccessfulProcessingStrategy

java.lang.Object

org.mule.routing.AbstractUntilSuccessfulProcessingStrategy

All Implemented Interfaces:

UntilSuccessfulProcessingStrategy

Direct Known Subclasses:

AsynchronousUntilSuccessfulProcessingStrategy, SynchronousUntilSuccessfulProcessingStrategy

public abstract class AbstractUntilSuccessfulProcessingStrategy
extends Object
implements UntilSuccessfulProcessingStrategy

Abstract class with common logic for until successful processing strategies.

Constructor Summary

Constructors

Constructor and Description
AbstractUntilSuccessfulProcessingStrategy()

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract MuleEvent	doRoute(MuleEvent event)
protected void	ensureSerializable(MuleMessage message)
protected UntilSuccessfulConfiguration	getUntilSuccessfulConfiguration()
protected MuleEvent	processEvent(MuleEvent event) Process the event through the configured route in the until-successful configuration.
protected MuleEvent	processResponseThroughAckResponseExpression(MuleEvent event)
MuleEvent	route(MuleEvent event)
void	setUntilSuccessfulConfiguration(UntilSuccessfulConfiguration untilSuccessfulConfiguration)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractUntilSuccessfulProcessingStrategy

public AbstractUntilSuccessfulProcessingStrategy()

Method Detail

setUntilSuccessfulConfiguration

public void setUntilSuccessfulConfiguration(UntilSuccessfulConfiguration untilSuccessfulConfiguration)

Specified by:

setUntilSuccessfulConfiguration in interface UntilSuccessfulProcessingStrategy

Parameters:

untilSuccessfulConfiguration - until successful configuration.

processEvent

protected MuleEvent processEvent(MuleEvent event)

Process the event through the configured route in the until-successful configuration.

Parameters:

event - the event to process through the until successful inner route.

Returns:

the response from the route if there's no ack expression. If there's ack expression then a message with the response event but with a payload defined by the ack expression.

processResponseThroughAckResponseExpression

protected MuleEvent processResponseThroughAckResponseExpression(MuleEvent event)

Parameters:

event - the response event from the until-successful route.

Returns:

the response message to be sent to the until successful caller.

getUntilSuccessfulConfiguration

protected UntilSuccessfulConfiguration getUntilSuccessfulConfiguration()

Returns:

configuration of the until-successful router.

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.

doRoute

protected abstract MuleEvent doRoute(MuleEvent event)
                              throws MessagingException

Throws:

MessagingException

ensureSerializable

protected void ensureSerializable(MuleMessage message)
                           throws NotSerializableException

Throws:

NotSerializableException