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(org.springframework.beans.factory.BeanFactory beanFactory) |
void |
setConversionService(org.springframework.core.convert.ConversionService conversionService) |
aggregateHeaders, getMessageBuilderFactory, 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(org.springframework.core.convert.ConversionService conversionService)
public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
setBeanFactory
in interface org.springframework.beans.factory.BeanFactoryAware
setBeanFactory
in class AbstractAggregatingMessageGroupProcessor
protected final Object aggregatePayloads(MessageGroup group, Map<String,Object> headers)
aggregatePayloads
in class AbstractAggregatingMessageGroupProcessor