public class AggregatorSpec extends CorrelationHandlerSpec<AggregatorSpec,org.springframework.integration.aggregator.AggregatingMessageHandler>
CorrelationHandlerSpec
for an AggregatingMessageHandler
.id, logger, 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(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. |
correlationExpression, correlationStrategy, correlationStrategy, discardChannel, discardChannel, expireGroupsUponTimeout, forceReleaseAdvice, groupTimeout, groupTimeout, groupTimeoutExpression, lockRegistry, messageStore, minimumTimeoutForEmptyGroups, processor, releaseExpression, releaseStrategy, releaseStrategy, sendPartialResultOnExpiry, taskScheduler
advice, autoStartup, order, phase, poller, requiresReply, sendTimeout
doGet, id, poller, poller
_this, get, getId
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(org.springframework.integration.aggregator.MessageGroupProcessor outputProcessor)
outputProcessor
- the processor.public AggregatorSpec expireGroupsUponCompletion(boolean expireGroupsUponCompletion)
expireGroupsUponCompletion
- the expireGroupsUponCompletion.AggregatingMessageHandler.setExpireGroupsUponCompletion(boolean)