public class MethodInvokingMessageGroupProcessor extends AbstractAggregatingMessageGroupProcessor
Constructor and Description |
---|
MethodInvokingMessageGroupProcessor(java.lang.Object target)
Creates a wrapper around the object passed in.
|
MethodInvokingMessageGroupProcessor(java.lang.Object target,
java.lang.reflect.Method method)
Creates a wrapper around the object passed in.
|
MethodInvokingMessageGroupProcessor(java.lang.Object target,
java.lang.String methodName)
Creates a wrapper around the object passed in.
|
Modifier and Type | Method and Description |
---|---|
protected java.lang.Object |
aggregatePayloads(MessageGroup group,
java.util.Map<java.lang.String,java.lang.Object> headers) |
void |
setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) |
void |
setConversionService(org.springframework.core.convert.ConversionService conversionService) |
aggregateHeaders, processMessageGroup
public MethodInvokingMessageGroupProcessor(java.lang.Object target)
target
- the object to wrappublic MethodInvokingMessageGroupProcessor(java.lang.Object target, java.lang.String methodName)
target
- the object to wrapmethodName
- the name of the method to invokepublic MethodInvokingMessageGroupProcessor(java.lang.Object target, java.lang.reflect.Method method)
target
- the object to wrapmethod
- the method to invokepublic void setConversionService(org.springframework.core.convert.ConversionService conversionService)
public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
protected final java.lang.Object aggregatePayloads(MessageGroup group, java.util.Map<java.lang.String,java.lang.Object> headers)
aggregatePayloads
in class AbstractAggregatingMessageGroupProcessor