public class AggregatorSpec extends CorrelationHandlerSpec<AggregatorSpec,org.springframework.integration.aggregator.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) |
AggregatorSpec |
outputProcessor(org.springframework.integration.aggregator.MessageGroupProcessor outputProcessor) |
AggregatorSpec |
processor(java.lang.Object target,
java.lang.String methodName) |
configure, correlationExpression, correlationStrategy, correlationStrategy, discardChannel, discardChannel, groupTimeout, groupTimeoutExpression, messageStore, minimumTimeoutForEmptyGroups, releaseExpression, releaseStrategy, releaseStrategy, sendPartialResultOnExpiry, taskScheduler_this, get, idpublic AggregatorSpec processor(java.lang.Object target, java.lang.String methodName)
processor in class CorrelationHandlerSpec<AggregatorSpec,org.springframework.integration.aggregator.AggregatingMessageHandler>public AggregatorSpec outputExpression(java.lang.String expression)
public AggregatorSpec outputProcessor(org.springframework.integration.aggregator.MessageGroupProcessor outputProcessor)
public AggregatorSpec expireGroupsUponCompletion(boolean expireGroupsUponCompletion)
protected org.springframework.integration.aggregator.AggregatingMessageHandler doGet()
doGet in class IntegrationComponentSpec<AggregatorSpec,org.springframework.integration.aggregator.AggregatingMessageHandler>