org.springframework.integration.aggregator
Class MethodInvokingMessageListProcessor<T>
java.lang.Object
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.aggregator.MethodInvokingMessageListProcessor<T>
- All Implemented Interfaces:
- BeanFactoryAware
public class MethodInvokingMessageListProcessor<T>
- extends AbstractExpressionEvaluator
A MessageListProcessor implementation that invokes a method on a target POJO.
- Since:
- 2.0
Method Summary |
T |
process(java.util.Collection<? extends Message<?>> messages,
java.util.Map<java.lang.String,java.lang.Object> aggregateHeaders)
|
java.lang.String |
toString()
|
Methods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator |
evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getEvaluationContext, setBeanFactory, setBeanResolver, setConversionService |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
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)
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
process
public T process(java.util.Collection<? extends Message<?>> messages,
java.util.Map<java.lang.String,java.lang.Object> aggregateHeaders)