Class MethodInvokingMessageListProcessor<T>
java.lang.Object
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.aggregator.MethodInvokingMessageListProcessor<T>
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,ManageableLifecycle
public class MethodInvokingMessageListProcessor<T> extends AbstractExpressionEvaluator implements ManageableLifecycle
A MessageListProcessor implementation that invokes a method on a target POJO.
- Since:
- 2.0
-
Field Summary
Fields inherited from class org.springframework.integration.util.AbstractExpressionEvaluator
EXPRESSION_PARSER, logger -
Constructor Summary
Constructors Constructor Description MethodInvokingMessageListProcessor(java.lang.Object targetObject, java.lang.Class<? extends java.lang.annotation.Annotation> annotationType)MethodInvokingMessageListProcessor(java.lang.Object targetObject, java.lang.reflect.Method method)MethodInvokingMessageListProcessor(java.lang.Object targetObject, java.lang.reflect.Method method, java.lang.Class<T> expectedType)MethodInvokingMessageListProcessor(java.lang.Object targetObject, java.lang.String methodName)MethodInvokingMessageListProcessor(java.lang.Object targetObject, java.lang.String methodName, java.lang.Class<T> expectedType) -
Method Summary
Modifier and Type Method Description booleanisRunning()Tprocess(java.util.Collection<org.springframework.messaging.Message<?>> messages, java.util.Map<java.lang.String,java.lang.Object> aggregateHeaders)voidsetBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)Specify a BeanFactory in order to enable resolution via@beanNamein the expression.voidsetUseSpelInvoker(boolean useSpelInvoker)Abooleanflag to use SpEL Expression evaluation orInvocableHandlerMethodfor target method invocation.voidstart()voidstop()java.lang.StringtoString()Methods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setConversionService
-
Constructor Details
-
MethodInvokingMessageListProcessor
public MethodInvokingMessageListProcessor(java.lang.Object targetObject, java.lang.reflect.Method method, java.lang.Class<T> expectedType) -
MethodInvokingMessageListProcessor
public MethodInvokingMessageListProcessor(java.lang.Object targetObject, java.lang.reflect.Method method) -
MethodInvokingMessageListProcessor
public MethodInvokingMessageListProcessor(java.lang.Object targetObject, java.lang.String methodName, java.lang.Class<T> expectedType) -
MethodInvokingMessageListProcessor
public MethodInvokingMessageListProcessor(java.lang.Object targetObject, java.lang.String methodName) -
MethodInvokingMessageListProcessor
public MethodInvokingMessageListProcessor(java.lang.Object targetObject, java.lang.Class<? extends java.lang.annotation.Annotation> annotationType)
-
-
Method Details
-
setBeanFactory
public void setBeanFactory(@NonNull org.springframework.beans.factory.BeanFactory beanFactory)Description copied from class:AbstractExpressionEvaluatorSpecify a BeanFactory in order to enable resolution via@beanNamein the expression.- Specified by:
setBeanFactoryin interfaceorg.springframework.beans.factory.BeanFactoryAware- Overrides:
setBeanFactoryin classAbstractExpressionEvaluator
-
setUseSpelInvoker
public void setUseSpelInvoker(boolean useSpelInvoker)Abooleanflag to use SpEL Expression evaluation orInvocableHandlerMethodfor target method invocation.- Parameters:
useSpelInvoker- to use SpEL Expression evaluation or not.- Since:
- 5.0
-
toString
public java.lang.String toString()- Overrides:
toStringin classjava.lang.Object
-
process
public T process(java.util.Collection<org.springframework.messaging.Message<?>> messages, java.util.Map<java.lang.String,java.lang.Object> aggregateHeaders) -
start
public void start()- Specified by:
startin interfaceorg.springframework.context.Lifecycle- Specified by:
startin interfaceManageableLifecycle
-
stop
public void stop()- Specified by:
stopin interfaceorg.springframework.context.Lifecycle- Specified by:
stopin interfaceManageableLifecycle
-
isRunning
public boolean isRunning()- Specified by:
isRunningin interfaceorg.springframework.context.Lifecycle- Specified by:
isRunningin interfaceManageableLifecycle
-