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