public class AggregatorSpec extends CorrelationHandlerSpec<AggregatorSpec,org.springframework.integration.aggregator.AggregatingMessageHandler>
messageStore, sendPartialResultOnExpiry
id, 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, groupTimeout, groupTimeoutExpression, messageStore, minimumTimeoutForEmptyGroups, releaseExpression, releaseStrategy, releaseStrategy, sendPartialResultOnExpiry, taskScheduler
_this, get, getId, id
public 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>