public class MethodInvokingMessageGroupProcessor extends AbstractAggregatingMessageGroupProcessor implements ManageableLifecycle
logger| 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) |
boolean |
isRunning() |
void |
setBeanFactory(BeanFactory beanFactory) |
void |
setConversionService(ConversionService conversionService) |
void |
start() |
void |
stop() |
aggregateHeaders, getHeadersFunction, getMessageBuilderFactory, processMessageGroup, setHeadersFunctionpublic 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 BeanFactoryAwaresetBeanFactory in class AbstractAggregatingMessageGroupProcessorprotected final Object aggregatePayloads(MessageGroup group, Map<String,Object> headers)
aggregatePayloads in class AbstractAggregatingMessageGroupProcessorpublic void start()
start in interface Lifecyclestart in interface ManageableLifecyclepublic void stop()
stop in interface Lifecyclestop in interface ManageableLifecyclepublic boolean isRunning()
isRunning in interface LifecycleisRunning in interface ManageableLifecycle