public class AggregatorSpec extends CorrelationHandlerSpec<AggregatorSpec,AggregatingMessageHandler>
adviceChaincomponentsToRegister, endpointFactoryBean, handlerlogger, PARSER, target| Modifier and Type | Method and Description |
|---|---|
AggregatorSpec |
expireGroupsUponCompletion(boolean expireGroupsUponCompletion) |
AggregatorSpec |
outputExpression(java.lang.String expression)
An expression to determine the output message from the released group.
|
AggregatorSpec |
outputProcessor(MessageGroupProcessor outputProcessor)
A processor to determine the output message from the released group.
|
AggregatorSpec |
processor(java.lang.Object target)
Configure the handler with
MethodInvokingCorrelationStrategy
and MethodInvokingReleaseStrategy using the target
object which should have methods annotated appropriately for each function. |
AggregatorSpec |
processor(java.lang.Object target,
java.lang.String methodName)
Configure the handler with
MethodInvokingCorrelationStrategy
and MethodInvokingReleaseStrategy using the target
object which should have methods annotated appropriately for each function. |
correlationExpression, correlationStrategy, correlationStrategy, discardChannel, discardChannel, expireGroupsUponTimeout, forceReleaseAdvice, groupTimeout, groupTimeout, groupTimeoutExpression, lockRegistry, messageStore, minimumTimeoutForEmptyGroups, releaseExpression, releaseStrategy, releaseStrategy, sendPartialResultOnExpiry, taskScheduleradvice, async, autoStartup, doGet, notPropagatedHeaders, order, phase, poller, requiresReply, role, sendTimeout, transactional, transactional, transactional, transactional, transactionalassertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller_this, afterPropertiesSet, destroy, get, getId, getObject, getObjectType, isSingletonpublic AggregatorSpec processor(java.lang.Object target)
MethodInvokingCorrelationStrategy
and MethodInvokingReleaseStrategy using the target
object which should have methods annotated appropriately for each function.
Also set the output processor.processor in class CorrelationHandlerSpec<AggregatorSpec,AggregatingMessageHandler>target - the target object.AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy),
AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)public AggregatorSpec processor(java.lang.Object target, java.lang.String methodName)
MethodInvokingCorrelationStrategy
and MethodInvokingReleaseStrategy using the target
object which should have methods annotated appropriately for each function.
Also set the output processor.target - the target object.methodName - The method name for the output processor (or 'null' in which case, the
target object must have an Aggregator annotation).public AggregatorSpec outputExpression(java.lang.String expression)
expression - the expression.public AggregatorSpec outputProcessor(MessageGroupProcessor outputProcessor)
outputProcessor - the processor.public AggregatorSpec expireGroupsUponCompletion(boolean expireGroupsUponCompletion)
expireGroupsUponCompletion - the expireGroupsUponCompletion.AggregatingMessageHandler.setExpireGroupsUponCompletion(boolean)