Package org.springframework.integration.aggregator

Class MethodInvokingCorrelationStrategy

java.lang.Object

org.springframework.integration.aggregator.MethodInvokingCorrelationStrategy

All Implemented Interfaces:

Aware, BeanFactoryAware, Lifecycle, CorrelationStrategy, ManageableLifecycle

public class MethodInvokingCorrelationStrategy
extends Object
implements CorrelationStrategy, BeanFactoryAware, ManageableLifecycle

CorrelationStrategy implementation that works as an adapter to another bean.

Author:

Marius Bogoevici, Dave Syer, Artem Bilan, Gary Russell

Constructor Summary

Constructors

Constructor	Description
MethodInvokingCorrelationStrategy(Object object, Method method)
MethodInvokingCorrelationStrategy(Object object, String methodName)

Method Summary

Modifier and Type	Method	Description
Object	getCorrelationKey(Message<?> message)	Find the correlation key for the given message.
boolean	isRunning()
void	setBeanFactory(BeanFactory beanFactory)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

MethodInvokingCorrelationStrategy

public MethodInvokingCorrelationStrategy(Object object,
 String methodName)

MethodInvokingCorrelationStrategy

public MethodInvokingCorrelationStrategy(Object object,
 Method method)

Method Details

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Specified by:

setBeanFactory in interface BeanFactoryAware

Throws:

BeansException

getCorrelationKey

public 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

Parameters:

message - The message.

Returns:

The correlation key.

start

public void start()

Specified by:

start in interface Lifecycle

Specified by:

start in interface ManageableLifecycle

stop

public void stop()

Specified by:

stop in interface Lifecycle

Specified by:

stop in interface ManageableLifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Lifecycle

Specified by:

isRunning in interface ManageableLifecycle