Spring Integration

org.springframework.integration.aggregator
Class ExpressionEvaluatingCorrelationStrategy

java.lang.Object
  extended by org.springframework.integration.aggregator.ExpressionEvaluatingCorrelationStrategy
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, CorrelationStrategy

public class ExpressionEvaluatingCorrelationStrategy
extends java.lang.Object
implements CorrelationStrategy, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean

CorrelationStrategy implementation that evaluates an expression.

Author:
Dave Syer, Oleg Zhurakousky

Constructor Summary
ExpressionEvaluatingCorrelationStrategy(org.springframework.expression.Expression expression)
           
ExpressionEvaluatingCorrelationStrategy(java.lang.String expressionString)
           
 
Method Summary
 void afterPropertiesSet()
           
 java.lang.Object getCorrelationKey(Message<?> message)
          Find the correlation key for the given message.
 void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ExpressionEvaluatingCorrelationStrategy

public ExpressionEvaluatingCorrelationStrategy(java.lang.String expressionString)

ExpressionEvaluatingCorrelationStrategy

public ExpressionEvaluatingCorrelationStrategy(org.springframework.expression.Expression expression)
Method Detail

getCorrelationKey

public java.lang.Object getCorrelationKey(Message<?> message)
Description copied from interface: CorrelationStrategy
Find the correlation key for the given message. If no key can be determined the strategy should not return null, but throw an exception.

Specified by:
getCorrelationKey in interface CorrelationStrategy

setBeanFactory

public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
                    throws org.springframework.beans.BeansException
Specified by:
setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware
Throws:
org.springframework.beans.BeansException

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception
Specified by:
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
Throws:
java.lang.Exception

Spring Integration