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, processMessageGroup
public 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.BeanFactoryAware
setBeanFactory
in class AbstractAggregatingMessageGroupProcessor
protected final java.lang.Object aggregatePayloads(MessageGroup group, java.util.Map<java.lang.String,java.lang.Object> headers)
aggregatePayloads
in class AbstractAggregatingMessageGroupProcessor
public void start()
start
in interface org.springframework.context.Lifecycle
public void stop()
stop
in interface org.springframework.context.Lifecycle
public boolean isRunning()
isRunning
in interface org.springframework.context.Lifecycle