Package org.springframework.integration.aggregator

Class MethodInvokingMessageListProcessor<T>

java.lang.Object

org.springframework.integration.util.AbstractExpressionEvaluator

org.springframework.integration.aggregator.MethodInvokingMessageListProcessor<T>

Type Parameters:

T - the method evaluation expecetd result type.

All Implemented Interfaces:

Aware, BeanFactoryAware, InitializingBean, Lifecycle, ManageableLifecycle

public class MethodInvokingMessageListProcessor<T>
extends AbstractExpressionEvaluator
implements ManageableLifecycle

A MessageListProcessor implementation that invokes a method on a target POJO.

Since:

2.0

Author:

Dave Syer, Artem Bilan, Gary Russell

Field Summary

Fields inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

EXPRESSION_PARSER, logger

Constructor Summary

Constructors

Constructor	Description
MethodInvokingMessageListProcessor(Object targetObject, Class<? extends Annotation> annotationType)
MethodInvokingMessageListProcessor(Object targetObject, Method method)
MethodInvokingMessageListProcessor(Object targetObject, Method method, Class<T> expectedType)
MethodInvokingMessageListProcessor(Object targetObject, String methodName)
MethodInvokingMessageListProcessor(Object targetObject, String methodName, Class<T> expectedType)

Method Summary

Modifier and Type	Method	Description
boolean	isRunning()
T	process(Collection<Message<?>> messages, Map<String,Object> aggregateHeaders)
void	setBeanFactory(BeanFactory beanFactory)	Specify a BeanFactory in order to enable resolution via @beanName in the expression.
void	setUseSpelInvoker(boolean useSpelInvoker)	A boolean flag to use SpEL Expression evaluation or InvocableHandlerMethod for target method invocation.
void	start()
void	stop()
String	toString()

Methods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setConversionService, setSimpleEvaluationContext

Methods inherited from class java.lang.Object

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

Constructor Details

MethodInvokingMessageListProcessor

public MethodInvokingMessageListProcessor(Object targetObject,
 Method method,
 Class<T> expectedType)

MethodInvokingMessageListProcessor

public MethodInvokingMessageListProcessor(Object targetObject,
 Method method)

MethodInvokingMessageListProcessor

public MethodInvokingMessageListProcessor(Object targetObject,
 String methodName,
 Class<T> expectedType)

MethodInvokingMessageListProcessor

public MethodInvokingMessageListProcessor(Object targetObject,
 String methodName)

MethodInvokingMessageListProcessor

public MethodInvokingMessageListProcessor(Object targetObject,
 Class<? extends Annotation> annotationType)

Method Details

setBeanFactory

public void setBeanFactory(@NonNull
 BeanFactory beanFactory)

Description copied from class: AbstractExpressionEvaluator

Specify a BeanFactory in order to enable resolution via @beanName in the expression.

Specified by:

setBeanFactory in interface BeanFactoryAware

Overrides:

setBeanFactory in class AbstractExpressionEvaluator

setUseSpelInvoker

public void setUseSpelInvoker(boolean useSpelInvoker)

A boolean flag to use SpEL Expression evaluation or InvocableHandlerMethod for target method invocation.

Parameters:

useSpelInvoker - to use SpEL Expression evaluation or not.

Since:

5.0

toString

public String toString()

Overrides:

toString in class Object

process

public T process(Collection<Message<?>> messages,
 Map<String,Object> aggregateHeaders)

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