public class MethodInvokingMessageGroupProcessor extends AbstractAggregatingMessageGroupProcessor implements ManageableLifecycle
logger| 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, getHeadersFunction, getMessageBuilderFactory, processMessageGroup, setHeadersFunctionpublic 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.Lifecyclestart in interface ManageableLifecyclepublic void stop()
stop in interface org.springframework.context.Lifecyclestop in interface ManageableLifecyclepublic boolean isRunning()
isRunning in interface org.springframework.context.LifecycleisRunning in interface ManageableLifecycle