public class AggregatorSpec extends CorrelationHandlerSpec<AggregatorSpec,org.springframework.integration.aggregator.AggregatingMessageHandler>
CorrelationHandlerSpec for an AggregatingMessageHandler.messageStore, sendPartialResultOnExpiryid, logger, PARSER, target| Modifier and Type | Method and Description |
|---|---|
protected org.springframework.integration.aggregator.AggregatingMessageHandler |
doGet() |
AggregatorSpec |
expireGroupsUponCompletion(boolean expireGroupsUponCompletion) |
AggregatorSpec |
outputExpression(java.lang.String expression)
An expression to determine the output message from the released group.
|
AggregatorSpec |
outputProcessor(org.springframework.integration.aggregator.MessageGroupProcessor outputProcessor)
A processor to determine the output message from the released group.
|
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. |
configure, correlationExpression, correlationStrategy, correlationStrategy, discardChannel, discardChannel, groupTimeout, groupTimeout, groupTimeoutExpression, messageStore, minimumTimeoutForEmptyGroups, processor, releaseExpression, releaseStrategy, releaseStrategy, sendPartialResultOnExpiry, taskScheduler_this, get, getId, idpublic 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(org.springframework.integration.aggregator.MessageGroupProcessor outputProcessor)
outputProcessor - the processor.public AggregatorSpec expireGroupsUponCompletion(boolean expireGroupsUponCompletion)
expireGroupsUponCompletion - the expireGroupsUponCompletion.AggregatingMessageHandler.setExpireGroupsUponCompletion(boolean)protected org.springframework.integration.aggregator.AggregatingMessageHandler doGet()
doGet in class IntegrationComponentSpec<AggregatorSpec,org.springframework.integration.aggregator.AggregatingMessageHandler>