public class MethodInvokingMessageGroupProcessor extends AbstractAggregatingMessageGroupProcessor implements org.springframework.context.Lifecycle
| 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) |
boolean |
isRunning() |
void |
setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) |
void |
setConversionService(org.springframework.core.convert.ConversionService conversionService) |
void |
start() |
void |
stop() |
aggregateHeaders, getMessageBuilderFactory, processMessageGrouppublic 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)
setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAwaresetBeanFactory in class AbstractAggregatingMessageGroupProcessorprotected final java.lang.Object aggregatePayloads(MessageGroup group, java.util.Map<java.lang.String,java.lang.Object> headers)
aggregatePayloads in class AbstractAggregatingMessageGroupProcessorpublic void start()
start in interface org.springframework.context.Lifecyclepublic void stop()
stop in interface org.springframework.context.Lifecyclepublic boolean isRunning()
isRunning in interface org.springframework.context.Lifecycle