org.springframework.integration.routingslip

Class ExpressionEvaluatingRoutingSlipRouteStrategy

java.lang.Object

org.springframework.integration.routingslip.ExpressionEvaluatingRoutingSlipRouteStrategy

All Implemented Interfaces:

Aware, BeanFactoryAware, InitializingBean, RoutingSlipRouteStrategy

public class ExpressionEvaluatingRoutingSlipRouteStrategy
extends Object
implements RoutingSlipRouteStrategy, BeanFactoryAware, InitializingBean

The Expression based RoutingSlipRouteStrategy implementation. The requestMessage and reply object are wrapped to the ExpressionEvaluatingRoutingSlipRouteStrategy.RequestAndReply which is used as a EvaluationContext rootObject. This is necessary to avoid a creation of a new EvaluationContext on each invocation when additional parameter can be populated as expression variable, but EvaluationContext isn't thread-safe.

The ExpressionEvaluatingRoutingSlipRouteStrategy can be used directly as a regular bean in the ApplicationContext and its beanName can be used from routingSlip header configuration.

Usage of ExpressionEvaluatingRoutingSlipRouteStrategy as a regular bean definition is a recommended way in case of distributed environment, when message with routingSlip header can be sent across the network. One of this case is a QueueChannel with persistent MessageStore, when ExpressionEvaluatingRoutingSlipRouteStrategy instance as a header value will be non-serializable.

This class is used internally from RoutingSlipHeaderValueMessageProcessor to populate routingSlip header value item, when the value from configuration contains expression definitions:

 <header-enricher>
     <routing-slip
           value="channel1; @routingSlipPojo.get(request, reply); request.headers[foo]"/>
 </header-enricher>
 
 

Since:

4.1

Author:

Artem Bilan, Gary Russell

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ExpressionEvaluatingRoutingSlipRouteStrategy.RequestAndReply

Constructor Summary

Constructors

Constructor and Description
ExpressionEvaluatingRoutingSlipRouteStrategy(Expression expression)
ExpressionEvaluatingRoutingSlipRouteStrategy(String expression)

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
Object	getNextPath(Message<?> requestMessage, Object reply) Get the next path for this routing slip.
void	setBeanFactory(BeanFactory beanFactory)
void	setIntegrationEvaluationContext(EvaluationContext evaluationContext)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ExpressionEvaluatingRoutingSlipRouteStrategy

public ExpressionEvaluatingRoutingSlipRouteStrategy(String expression)

ExpressionEvaluatingRoutingSlipRouteStrategy

public ExpressionEvaluatingRoutingSlipRouteStrategy(Expression expression)

Method Detail

setIntegrationEvaluationContext

public void setIntegrationEvaluationContext(EvaluationContext evaluationContext)

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Specified by:

setBeanFactory in interface BeanFactoryAware

Throws:

BeansException

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

getNextPath

public Object getNextPath(Message<?> requestMessage,
                          Object reply)

Description copied from interface: RoutingSlipRouteStrategy

Get the next path for this routing slip.

Specified by:

getNextPath in interface RoutingSlipRouteStrategy

Parameters:

requestMessage - the request message.

reply - the reply - depending on context, this may be a user-level domain object, a Message or a AbstractIntegrationMessageBuilder.

Returns:

a channel name or another RoutingSlipRouteStrategy.

toString

public String toString()

Overrides:

toString in class Object